diff --git a/internal/admin/router_test.go b/internal/admin/router_test.go index e01b6d0..db397f6 100644 --- a/internal/admin/router_test.go +++ b/internal/admin/router_test.go @@ -54,20 +54,20 @@ func doReq(t *testing.T, r *gin.Engine, method, path, token string, body any) *h func fullClusterMap(id string) map[string]any { return map[string]any{ - "id": id, - "name": id + "-name", - "rm_url": "http://rm.example.com:8088", - "shs_url": "http://shs.example.com:18080", - "spark_submit_execute_bin": "/usr/bin/spark-submit", - "is_active": true, - "auth_type": "basic", - "auth_username": "admin", - "auth_password": "real-secret", - "ssl_verify": false, - "ssl_ca_bundle": "", - "url_allowlist": []string{"*.example.com"}, - "default_submit_args": []string{"--master", "yarn"}, - "rate_limit_per_min": 10, + "id": id, + "name": id + "-name", + "rm_url": "http://rm.example.com:8088", + "shs_url": "http://shs.example.com:18080", + "spark_submit_execute_bin": "/usr/bin/spark-submit", + "is_active": true, + "auth_type": "basic", + "auth_username": "admin", + "auth_password": "real-secret", + "ssl_verify": false, + "ssl_ca_bundle": "", + "url_allowlist": []string{"*.example.com"}, + "default_submit_args": []string{"--master", "yarn"}, + "rate_limit_per_min": 10, } } diff --git a/internal/executor/spark_submit_test.go b/internal/executor/spark_submit_test.go index 79a718d..eff7939 100644 --- a/internal/executor/spark_submit_test.go +++ b/internal/executor/spark_submit_test.go @@ -29,8 +29,8 @@ func TestRun_FakeBinary(t *testing.T) { defer cancel() res, err := Run(ctx, SparkSubmitOpts{ - Binary: "/bin/echo", - Args: []string{"--master", "yarn; rm -rf /tmp/this-should-not-exist"}, + Binary: "/bin/echo", + Args: []string{"--master", "yarn; rm -rf /tmp/this-should-not-exist"}, Timeout: 3 * time.Second, }) if err != nil { @@ -54,8 +54,8 @@ func TestRun_NonZeroExit(t *testing.T) { t.Skip("uses unix binary") } res, err := Run(context.Background(), SparkSubmitOpts{ - Binary: "/bin/sh", - Args: []string{"-c", "exit 7"}, + Binary: "/bin/sh", + Args: []string{"-c", "exit 7"}, Timeout: 3 * time.Second, }) if err == nil {