dont consume resources for acs stopped tasks

agent/engine/docker_task_engine.go

@@ -392,6 +392,12 @@ func (engine *DockerTaskEngine) monitorQueuedTasks(ctx context.Context) {
 				if err != nil {
 					break
 				}
+				taskDesiredStatus := task.GetDesiredStatus()
+				if taskDesiredStatus.Terminal() {
+					logger.Info("Task desired status STOPPED while waiting for host resources, progressing without consuming resources", logger.Fields{field.TaskARN: task.Arn})
+					engine.returnWaitingTask()
+					continue
+				}
 				taskHostResources := task.ToHostResources()
 				consumed, err := task.engine.hostResourceManager.consume(task.Arn, taskHostResources)
 				if err != nil {
@@ -409,6 +415,12 @@ func (engine *DockerTaskEngine) monitorQueuedTasks(ctx context.Context) {
 	}
 }
 
+// To be called when resources are not to be consumed by host resource manager, just dequeues and returns
+func (engine *DockerTaskEngine) returnWaitingTask() {
+	task, _ := engine.dequeueTask()
+	task.consumedHostResourceEvent <- struct{}{}
+}
+
 func (engine *DockerTaskEngine) failWaitingTask(err error) {
 	task, _ := engine.dequeueTask()
 	logger.Error(fmt.Sprintf("Error consuming resources due to invalid task config : %s", err.Error()), logger.Fields{field.TaskARN: task.Arn})