fix(controller): Mark workflows wait for semaphore as pending. Fixes #…

…6351 (#6356) Signed-off-by: Alex Collins <alex_collins@intuit.com>
argoproj · Jul 22, 2021 · 092b427 · 092b427
1 parent 4535396
commit 092b427
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go
@@ -229,7 +229,11 @@ func (woc *wfOperationCtx) operate(ctx context.Context) {
 		woc.updated = wfUpdate
 		if !acquired {
 			woc.log.Warn("Workflow processing has been postponed due to concurrency limit")
-			woc.wf.Status.Message = msg
+			phase := woc.wf.Status.Phase
+			if phase == wfv1.WorkflowUnknown {
+				phase = wfv1.WorkflowPending
+			}
+			woc.markWorkflowPhase(ctx, phase, msg)
 			return
 		}
 	}