From f6dc5d3fd58ceded474ca5f5f8e29918546aa7a2 Mon Sep 17 00:00:00 2001 From: EC2 Default User Date: Wed, 10 Jul 2024 21:37:10 +0000 Subject: [PATCH] add delay before sending TaskStopVerification message --- agent/engine/task_manager.go | 2 ++ ecs-agent/acs/session/task_manifest_responder.go | 3 +++ 2 files changed, 5 insertions(+) diff --git a/agent/engine/task_manager.go b/agent/engine/task_manager.go index 661e1f90d2..d7446e4a17 100644 --- a/agent/engine/task_manager.go +++ b/agent/engine/task_manager.go @@ -421,6 +421,8 @@ func (mtask *managedTask) handleDesiredStatusChange(desiredStatus apitaskstatus. field.DesiredStatus: desiredStatus.String(), field.Sequence: seqnum, }) + logger.Info("Sleeping 45 seconds before applying acs transition") + time.Sleep(45 * time.Second) if desiredStatus <= mtask.GetDesiredStatus() { logger.Debug("Redundant task transition; ignoring", logger.Fields{ field.TaskID: mtask.GetID(), diff --git a/ecs-agent/acs/session/task_manifest_responder.go b/ecs-agent/acs/session/task_manifest_responder.go index ec573945b9..a0b1d1160a 100644 --- a/ecs-agent/acs/session/task_manifest_responder.go +++ b/ecs-agent/acs/session/task_manifest_responder.go @@ -16,6 +16,7 @@ package session import ( "fmt" "sync" + "time" "github.com/aws/amazon-ecs-agent/ecs-agent/acs/model/ecsacs" "github.com/aws/amazon-ecs-agent/ecs-agent/logger" @@ -176,6 +177,8 @@ func (tmr *taskManifestResponder) sendTaskStopVerification(message *ecsacs.TaskM if len(tasksToStop) == 0 { return } + logger.Info("sleeping 30 seconds before sending TaskStopVerification message") + time.Sleep(30 * time.Second) // Create a list of stop candidates to send one debug message. var taskARNList []string for _, task := range tasksToStop {