From cabe46adfa57a58c7bdc8235e1a5ab8270429c6e Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Tue, 17 Dec 2024 14:35:24 -0800 Subject: [PATCH] fix test Signed-off-by: Kevin Su --- flyteplugins/go/tasks/plugins/webapi/agent/plugin.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go index 3015edaf2e..4f518ced55 100644 --- a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go +++ b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go @@ -154,7 +154,7 @@ func (p *Plugin) ExecuteTaskSync( stream, err := client.ExecuteTaskSync(ctx) if err != nil { logger.Errorf(ctx, "failed to execute task from agent with %v", err) - return nil, nil, fmt.Errorf("failed to execute task from agent with: %v", err) + return nil, nil, fmt.Errorf("failed to execute task from agent with %v", err) } headerProto := &admin.ExecuteTaskSyncRequest{ @@ -203,7 +203,7 @@ func (p *Plugin) ExecuteTaskSync( LogLinks: resource.GetLogLinks(), CustomInfo: resource.GetCustomInfo(), AgentError: resource.GetAgentError(), - }, fmt.Errorf("failed to execute task from agent with %v", err) + }, nil } func (p *Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest webapi.Resource, err error) {