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

…6351 (#6356) Signed-off-by: Alex Collins <alex_collins@intuit.com>
argoproj · Jul 27, 2021 · 069816a · 069816a
1 parent 791c26b
commit 069816a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go
@@ -228,7 +228,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
 		}
 	}