diff --git a/workflow/controller/exec_control.go b/workflow/controller/exec_control.go index add474b303a1..fa9d9b552708 100644 --- a/workflow/controller/exec_control.go +++ b/workflow/controller/exec_control.go @@ -20,7 +20,10 @@ func (woc *wfOperationCtx) applyExecutionControl(pod *apiv1.Pod, wfNodesLock *sy } nodeID := woc.nodeID(pod) - node := woc.wf.Status.Nodes[nodeID] + node, ok := woc.wf.Status.Nodes[nodeID] + if !ok { + return + } //node is already completed if node.Fulfilled() { return