lib/hako/schedulers/ecs.rb in hako-1.6.1 vs lib/hako/schedulers/ecs.rb in hako-1.6.2

- old
+ new

@@ -882,10 +882,12 @@ container_instances = ecs_client.list_container_instances(cluster: @cluster).flat_map do |c| if c.container_instance_arns.empty? [] else - ecs_client.describe_container_instances(cluster: @cluster, container_instances: c.container_instance_arns).container_instances + ecs_client.describe_container_instances(cluster: @cluster, container_instances: c.container_instance_arns).container_instances.select do |container_instance| + container_instance.agent_connected && container_instance.status == 'ACTIVE' + end end end if has_capacity?(task_definition, container_instances) Hako.logger.info("There's remaining capacity. Start retrying...") return true