diff --git a/workflow/controller/dag.go b/workflow/controller/dag.go index 1f5601830751..420cf30b3999 100644 --- a/workflow/controller/dag.go +++ b/workflow/controller/dag.go @@ -106,6 +106,10 @@ func (d *dagContext) assessDAGPhase(targetTasks []string, nodes map[string]wfv1. } func hasMoreRetries(node *wfv1.NodeStatus, wf *wfv1.Workflow) bool { + if node.Phase == wfv1.NodeSucceeded { + return false + } + if len(node.Children) == 0 { return true }