fix(api): load to delete run when updating node run job status (#5208)

ovh · May 27, 2020 · ec74def · ec74def
1 parent 71bb5bf
commit ec74def
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/engine/api/workflow/execute_node_job_run.go b/engine/api/workflow/execute_node_job_run.go
@@ -161,7 +161,9 @@ func UpdateNodeJobRunStatus(ctx context.Context, db gorp.SqlExecutor, store cach
 		job.Status = status
 
 		_, next := observability.Span(ctx, "workflow.LoadRunByID")
-		wf, errLoadWf := LoadRunByID(db, nodeRun.WorkflowRunID, LoadRunOptions{})
+		wf, errLoadWf := LoadRunByID(db, nodeRun.WorkflowRunID, LoadRunOptions{
+			WithDeleted: true,
+		})
 		next()
 		if errLoadWf != nil {
 			return nil, sdk.WrapError(errLoadWf, "workflow.UpdateNodeJobRunStatus> Unable to load run id %d", nodeRun.WorkflowRunID)