fix: Updating complated node status

Signed-off-by: Saravanan Balasubramanian <sarabala1979@gmail.com>
argoproj · Apr 12, 2022 · e97b0e6 · e97b0e6
1 parent 4e20442
commit e97b0e6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/workflow/controller/exec_control.go b/workflow/controller/exec_control.go
@@ -21,7 +21,11 @@ func (woc *wfOperationCtx) applyExecutionControl(ctx context.Context, pod *apiv1
 	}
 
 	nodeID := woc.nodeID(pod)
-
+	node := woc.wf.Status.Nodes[nodeID]
+	//node is already completed
+	if node.Fulfilled() {
+		return
+	}
 	switch pod.Status.Phase {
 	case apiv1.PodSucceeded, apiv1.PodFailed:
 		// Skip any pod which are already completed