Fix the bug where container state change was not submitted under race condition

CHANGELOG.md

@@ -3,6 +3,7 @@
 ## Unreleased
 
 ## 1.15.1
+* Bug - Fixed a bug where container state information wasn't reported. [#1067](https://github.com/aws/amazon-ecs-agent/pull/1067)
 * Bug - Fixed a bug where a task can be blocked in creating state. [#1048](https://github.com/aws/amazon-ecs-agent/pull/1048)
 * Bug - Fixed dynamic HostPort in container metadata. [#1052](https://github.com/aws/amazon-ecs-agent/pull/1052)
 

agent/api/ecsclient/client.go

@@ -318,13 +318,13 @@ func (client *APIECSClient) SubmitTaskStateChange(change api.TaskStateChange) er
 		return errors.New("ecs api client: SubmitTaskStateChange called with an invalid change")
 	}
 
-	if change.Status != api.TaskRunning && change.Status != api.TaskStopped {
+	if change.Status != api.TaskRunning && change.Status != api.TaskStopped && len(change.Containers) == 0 {
 		seelog.Debugf("Not submitting unsupported upstream task state: %s", change.Status.String())
 		// Not really an error
 		return nil
 	}
 
-	status := change.Status.String()
+	status := change.Status.BackendStatus()
 
 	req := ecs.SubmitTaskStateChangeInput{
 		Cluster: aws.String(client.config.Cluster),

agent/api/ecsclient/client_test.go

@@ -675,7 +675,6 @@ func TestSubmitTaskStateChangeWithAttachments(t *testing.T) {
 	assert.NoError(t, err, "Unable to submit task state change with attachments")
 }
 
-//
 func TestSubmitTaskStateChangeWithoutAttachments(t *testing.T) {
 	mockCtrl := gomock.NewController(t)
 	defer mockCtrl.Finish()
@@ -696,3 +695,42 @@ func TestSubmitTaskStateChangeWithoutAttachments(t *testing.T) {
 	})
 	assert.NoError(t, err, "Unable to submit task state change with no attachments")
 }
+
+// TestSubmitContainerStateChangeWhileTaskInPending tests the container state change was submitted
+// when the task is still in pending state
+func TestSubmitContainerStateChangeWhileTaskInPending(t *testing.T) {
+	mockCtrl := gomock.NewController(t)
+	defer mockCtrl.Finish()
+
+	client, _, mockSubmitStateClient := NewMockClient(mockCtrl, ec2.NewBlackholeEC2MetadataClient(), nil)
+	mockSubmitStateClient.EXPECT().SubmitTaskStateChange(&taskSubmitInputMatcher{
+		ecs.SubmitTaskStateChangeInput{
+			Cluster: strptr(configuredCluster),
+			Task:    strptr("arn"),
+			Status:  strptr("PENDING"),
+			Reason:  strptr(""),
+			Containers: []*ecs.ContainerStateChange{
+				{
+					ContainerName:   strptr("container"),
+					Status:          strptr("RUNNING"),
+					NetworkBindings: []*ecs.NetworkBinding{},
+				},
+			},
+		},
+	})
+
+	taskStateChangePending := api.TaskStateChange{
+		Status:  api.TaskCreated,
+		TaskARN: "arn",
+		Containers: []api.ContainerStateChange{
+			{
+				TaskArn:       "arn",
+				ContainerName: "container",
+				Status:        api.ContainerRunning,
+			},
+		},
+	}
+
+	err := client.SubmitTaskStateChange(taskStateChangePending)
+	assert.NoError(t, err)
+}