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