fix: task worker requeue wrong task. Fixes #8139 (#8186)

Signed-off-by: wujayway <wujayway@gmail.com>
argoproj · Apr 17, 2022 · 7d00fa9 · 7d00fa9
1 parent ed6907f
commit 7d00fa9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/workflow/executor/agent.go b/workflow/executor/agent.go
@@ -116,7 +116,11 @@ func (ae *AgentExecutor) Agent(ctx context.Context) error {
 }
 
 func (ae *AgentExecutor) taskWorker(ctx context.Context, taskQueue chan task, responseQueue chan response) {
-	for task := range taskQueue {
+	for {
+		task, ok := <-taskQueue
+		if !ok {
+			break
+		}
 		nodeID, tmpl := task.NodeId, task.Template
 		log := log.WithField("nodeID", nodeID)