test

Signed-off-by: Kevin Su <pingsutw@apache.org>
flyteorg · Sep 26, 2023 · 9944aae · 9944aae
1 parent e1fd8a4
commit 9944aae
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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