diff --git a/workflow/controller/dag.go b/workflow/controller/dag.go index dcd9c263209a..5321f5346024 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 }