diff --git a/workflow/controller/dag.go b/workflow/controller/dag.go index 5321f5346024..5a80706a1d85 100644 --- a/workflow/controller/dag.go +++ b/workflow/controller/dag.go @@ -79,7 +79,9 @@ func (d *dagContext) assessDAGPhase(targetTasks []string, nodes map[string]wfv1. unsuccessfulPhase = node.Phase } if node.Type == wfv1.NodeTypeRetry { - if hasMoreRetries(&node, d.wf) { + if node.Successful() { + retriesExhausted = false + } else if hasMoreRetries(&node, d.wf) { retriesExhausted = false } }