ongoing

sanderegg · sanderegg · commit 105be6f1ce02 · 2025-09-25T17:39:21.000+02:00
diff --git a/services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_provider_computational.py b/services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_provider_computational.py
@@ -140,7 +140,7 @@ async def compute_cluster_used_resources(
         list_of_used_resources: list[Resources] = await logged_gather(
             *(self.compute_node_used_resources(app, i) for i in instances)
         )
-        counter = collections.Counter()
+        counter: collections.Counter = collections.Counter()
         for result in list_of_used_resources:
             counter.update(result.as_flat_dict())
 
diff --git a/services/autoscaling/src/simcore_service_autoscaling/utils/utils_docker.py b/services/autoscaling/src/simcore_service_autoscaling/utils/utils_docker.py
@@ -393,7 +393,7 @@ async def compute_cluster_used_resources(
     list_of_used_resources: list[Resources] = await logged_gather(
         *(compute_node_used_resources(docker_client, node) for node in nodes)
     )
-    flat_counter = collections.Counter()
+    flat_counter: collections.Counter = collections.Counter()
     for result in list_of_used_resources:
         flat_counter.update(result.as_flat_dict())
     flat_counter.setdefault("cpus", 0)

Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ async def compute_cluster_used_resources(`
`140`	`140`	`list_of_used_resources: list[Resources] = await logged_gather(`
`141`	`141`	`*(self.compute_node_used_resources(app, i) for i in instances)`
`142`	`142`	`)`
`143`		`- counter = collections.Counter()`
	`143`	`+ counter: collections.Counter = collections.Counter()`
`144`	`144`	`for result in list_of_used_resources:`
`145`	`145`	`counter.update(result.as_flat_dict())`
`146`	`146`
Original file line number	Diff line number	Diff line change
`@@ -393,7 +393,7 @@ async def compute_cluster_used_resources(`
`393`	`393`	`list_of_used_resources: list[Resources] = await logged_gather(`
`394`	`394`	`*(compute_node_used_resources(docker_client, node) for node in nodes)`
`395`	`395`	`)`
`396`		`- flat_counter = collections.Counter()`
	`396`	`+ flat_counter: collections.Counter = collections.Counter()`
`397`	`397`	`for result in list_of_used_resources:`
`398`	`398`	`flat_counter.update(result.as_flat_dict())`
`399`	`399`	`flat_counter.setdefault("cpus", 0)`