diff --git a/workflow/controller/exec_control.go b/workflow/controller/exec_control.go index 8d7a97bbaa21..add474b303a1 100644 --- a/workflow/controller/exec_control.go +++ b/workflow/controller/exec_control.go @@ -1,7 +1,6 @@ package controller import ( - "context" "fmt" "sync" "time" @@ -15,7 +14,7 @@ import ( // applyExecutionControl will ensure a pod's execution control annotation is up-to-date // kills any pending and running pods when workflow has reached it's deadline -func (woc *wfOperationCtx) applyExecutionControl(ctx context.Context, pod *apiv1.Pod, wfNodesLock *sync.RWMutex) { +func (woc *wfOperationCtx) applyExecutionControl(pod *apiv1.Pod, wfNodesLock *sync.RWMutex) { if pod == nil { return } diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go index ebe860d59c0a..d1bee459454b 100644 --- a/workflow/controller/operator.go +++ b/workflow/controller/operator.go @@ -1020,7 +1020,7 @@ func (woc *wfOperationCtx) podReconciliation(ctx context.Context) error { go func(pod *apiv1.Pod) { defer wg.Done() performAssessment(pod) - woc.applyExecutionControl(ctx, pod, wfNodesLock) + woc.applyExecutionControl(pod, wfNodesLock) <-parallelPodNum }(pod) }