File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed
services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -154,15 +154,13 @@ async def _analyze_current_cluster(
154154 node_used_resources = await auto_scaling_mode .compute_node_used_resources (
155155 app , instance
156156 )
157- # available resources are total - used -> that means something is still going on on the instance (e.g. processing tasks)
158157 active_nodes .append (
159158 dataclasses .replace (
160159 instance ,
161160 available_resources = instance .ec2_instance .resources
162161 - node_used_resources ,
163162 )
164163 )
165-
166164 elif utils_docker .is_instance_drained (instance ):
167165 all_drained_nodes .append (instance )
168166 elif await auto_scaling_mode .is_instance_retired (app , instance ):
@@ -1007,10 +1005,7 @@ async def _find_drainable_nodes(
10071005 drainable_nodes : list [AssociatedInstance ] = []
10081006
10091007 for instance in cluster .active_nodes :
1010- if instance .has_assigned_tasks () or (
1011- instance .available_resources < instance .ec2_instance .resources
1012- ):
1013- # NOTE: we do not (yet) write down processing tasks to the node, so we check also if available resources are less than total resources
1008+ if instance .has_assigned_tasks ():
10141009 await utils_docker .set_node_found_empty (
10151010 get_docker_client (app ), instance .node , empty = False
10161011 )
You can’t perform that action at this time.
0 commit comments