diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go index f11eda2bc4a3..905a1fbb1cfe 100644 --- a/workflow/controller/operator.go +++ b/workflow/controller/operator.go @@ -1144,7 +1144,7 @@ func (woc *wfOperationCtx) executeTemplate(nodeName string, orgTmpl wfv1.Templat // Check if we exceeded template or workflow parallelism and immediately return if we did if err := woc.checkParallelism(processedTmpl, node, boundaryID); err != nil { - return woc.initializeNodeOrMarkError(node, nodeName, wfv1.NodeTypeSkipped, orgTmpl, boundaryID, err), err + return node, err } // If the user has specified retries, node becomes a special retry node.