ensure autoscaling counts at least 1 CPU per task

sanderegg · sanderegg · commit 50443a616617 · 2025-09-19T23:26:13.000+02:00
diff --git a/services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_utils_computational.py b/services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_utils_computational.py
@@ -16,7 +16,9 @@
 
 def resources_from_dask_task(task: DaskTask) -> Resources:
     return Resources(
-        cpus=task.required_resources.get("CPU", _DEFAULT_MAX_CPU),
+        cpus=min(
+            task.required_resources.get("CPU", _DEFAULT_MAX_CPU), 1.0
+        ),  # NOTE: dask-workers use 1 thread per CPU so going below will not scale
         ram=task.required_resources.get("RAM", _DEFAULT_MAX_RAM),
     )
 

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,9 @@`
`16`	`16`
`17`	`17`	`def resources_from_dask_task(task: DaskTask) -> Resources:`
`18`	`18`	`return Resources(`
`19`		`- cpus=task.required_resources.get("CPU", _DEFAULT_MAX_CPU),`
	`19`	`+ cpus=min(`
	`20`	`+ task.required_resources.get("CPU", _DEFAULT_MAX_CPU), 1.0`
	`21`	`+ ), # NOTE: dask-workers use 1 thread per CPU so going below will not scale`
`20`	`22`	`ram=task.required_resources.get("RAM", _DEFAULT_MAX_RAM),`
`21`	`23`	`)`
`22`	`24`