Skip to content

Commit 14e2253

Browse files
committed
Add task stop verification ack to ecs-agent module
1 parent 0be8253 commit 14e2253

File tree

4 files changed

+13
-0
lines changed

4 files changed

+13
-0
lines changed

agent/vendor/github.com/aws/amazon-ecs-agent/ecs-agent/metrics/constants.go

+5
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,9 @@ func (r *taskStopVerificationACKResponder) handleTaskStopVerificationACK(message
6363
return errors.New("Invalid messageID received: " + ackMessageID + " Manifest Message ID: " + manifestMessageID)
6464
}
6565

66+
// Reset the message id so that the message with same message id is not processed twice.
67+
r.messageIDAccessor.SetMessageID("")
68+
6669
// Loop through all tasks in the verified stop list and set the desired status of each one to STOPPED.
6770
tasksToStop := message.StopTasks
6871
for _, task := range tasksToStop {

ecs-agent/metrics/constants.go

+5
Original file line numberDiff line numberDiff line change
@@ -26,4 +26,9 @@ const (
2626
// AttachResourceResponder
2727
attachResourceResponderNamespace = "ResourceAttachment"
2828
ResourceValidationMetricName = attachResourceResponderNamespace + ".Validation"
29+
30+
// TaskManifestResponder, TaskStopVerificationACKResponder
31+
taskManifestResponderNamespace = "TaskManifestResponder"
32+
TaskStoppedMetricName = taskManifestResponderNamespace + ".TaskStopped"
33+
TaskManifestHandlingDuration = taskManifestResponderNamespace + ".Duration"
2934
)

0 commit comments

Comments
 (0)