From 9944aae39c0303f0e4939a35ec977b58854b7e63 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Mon, 25 Sep 2023 23:20:20 -0700 Subject: [PATCH] test Signed-off-by: Kevin Su --- go/tasks/plugins/webapi/agent/plugin.go | 1 - go/tasks/plugins/webapi/databricks/plugin.go | 2 +- go/tasks/plugins/webapi/snowflake/plugin.go | 2 +- 3 files changed, 2 insertions(+), 3 deletions(-) diff --git a/go/tasks/plugins/webapi/agent/plugin.go b/go/tasks/plugins/webapi/agent/plugin.go index 24e61d315..15de89511 100644 --- a/go/tasks/plugins/webapi/agent/plugin.go +++ b/go/tasks/plugins/webapi/agent/plugin.go @@ -121,7 +121,6 @@ func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextR } func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest webapi.Resource, err error) { - logger.Infof(ctx, "Getting task metadata [%v]", taskCtx.ResourceMeta()) if taskCtx.ResourceMeta() == nil { return nil, fmt.Errorf("resource metadata is nil") } diff --git a/go/tasks/plugins/webapi/databricks/plugin.go b/go/tasks/plugins/webapi/databricks/plugin.go index bb38a983b..e34b466dc 100644 --- a/go/tasks/plugins/webapi/databricks/plugin.go +++ b/go/tasks/plugins/webapi/databricks/plugin.go @@ -179,7 +179,7 @@ func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest weba jobID := fmt.Sprintf("%.0f", data["job_id"]) lifeCycleState := fmt.Sprintf("%s", jobState["life_cycle_state"]) resultState := fmt.Sprintf("%s", jobState["result_state"]) - return &ResourceWrapper{ + return ResourceWrapper{ StatusCode: resp.StatusCode, JobID: jobID, LifeCycleState: lifeCycleState, diff --git a/go/tasks/plugins/webapi/snowflake/plugin.go b/go/tasks/plugins/webapi/snowflake/plugin.go index 8a22e90ee..850497e99 100644 --- a/go/tasks/plugins/webapi/snowflake/plugin.go +++ b/go/tasks/plugins/webapi/snowflake/plugin.go @@ -160,7 +160,7 @@ func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest weba return nil, err } message := fmt.Sprintf("%v", data["message"]) - return &ResourceWrapper{ + return ResourceWrapper{ StatusCode: resp.StatusCode, Message: message, }, nil