File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
services/autoscaling/src/simcore_service_autoscaling/modules Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -1217,10 +1217,13 @@ async def auto_scale_cluster(
12171217 If there are such tasks, this method will allocate new machines in AWS to cope with
12181218 the additional load.
12191219 """
1220+ # current state
12201221 allowed_instance_types = await _sorted_allowed_instance_types (app )
12211222 cluster = await _analyze_current_cluster (
12221223 app , auto_scaling_mode , allowed_instance_types
12231224 )
1225+
1226+ # cleanup
12241227 cluster = await _cleanup_disconnected_nodes (app , cluster )
12251228 cluster = await _terminate_broken_ec2s (app , cluster )
12261229 cluster = await _make_pending_buffer_ec2s_join_cluster (app , cluster )
@@ -1229,8 +1232,11 @@ async def auto_scale_cluster(
12291232 )
12301233 cluster = await _drain_retired_nodes (app , cluster )
12311234
1235+ # desired state
12321236 cluster = await _autoscale_cluster (
12331237 app , cluster , auto_scaling_mode , allowed_instance_types
12341238 )
1239+
1240+ # notify
12351241 await _notify_machine_creation_progress (app , cluster , auto_scaling_mode )
12361242 await _notify_autoscaling_status (app , cluster , auto_scaling_mode )
You can’t perform that action at this time.
0 commit comments