diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go index 8cc7b4ed675b..14a4966384b4 100644 --- a/workflow/controller/operator.go +++ b/workflow/controller/operator.go @@ -910,7 +910,14 @@ func (woc *wfOperationCtx) podReconciliation() error { // If the node is pending and the pod does not exist, it could be the case that we want to try to submit it // again instead of marking it as an error. Check if that's the case. - if node.Pending() || recentlyStarted { + if node.Pending() { + continue + } + if recentlyStarted { + // If the pod was deleted, then we it is possible that the controller never get another informer message about it. + // In this case, the workflow will only be requeued after the resync period (20m). This means + // workflow will not update for 20m. Requeuing here prevents that happening. + woc.requeue(defaultRequeueTime) continue }