fix: Correct error handling in Delete function (#6269)

flyteorg · Feb 25, 2025 · 8fc1a30 · 8fc1a30
1 parent 49a2dd6
commit 8fc1a30
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
@@ -257,7 +257,10 @@ func (p *Plugin) Delete(ctx context.Context, taskCtx webapi.DeleteContext) error
 		ResourceMeta: metadata.AgentResourceMeta,
 	}
 	_, err = client.DeleteTask(finalCtx, request)
-	return fmt.Errorf("failed to delete task from agent with %v", err)
+	if err != nil {
+		return fmt.Errorf("failed to delete task from agent with %v", err)
+	}
+	return nil
 }
 
 func (p *Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase core.PhaseInfo, err error) {