fix: requeue not delete the considererd Task flag (#8194)

Signed-off-by: maybaby <berlinsaint@126.com>
argoproj · May 3, 2022 · b0d8be2 · b0d8be2
1 parent d199882
commit b0d8be2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/workflow/executor/agent.go b/workflow/executor/agent.go
@@ -155,6 +155,7 @@ func (ae *AgentExecutor) taskWorker(ctx context.Context, taskQueue chan task, re
 		}
 		if requeue > 0 {
 			time.AfterFunc(requeue, func() {
+				delete(ae.consideredTasks, nodeID)
 				taskQueue <- task
 			})
 		}