ensure autoscaling counts at least 1 CPU per task

Author: sanderegg

services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_provider_computational.py

@@ -88,7 +88,13 @@ async def list_unrunnable_tasks(self, app: FastAPI) -> list[DaskTask]:
 
     def get_task_required_resources(self, task) -> Resources:
         assert self  # nosec
-        return utils.resources_from_dask_task(task)
+        task_required_resources = utils.resources_from_dask_task(task)
+        # ensure cpu is set at least to 1 as dask-workers use 1 thread per CPU
+        if task_required_resources.cpus < 1.0:
+            task_required_resources = task_required_resources.model_copy(
+                update={"cpus": 1.0}
+            )
+        return task_required_resources
 
     async def get_task_defined_instance(
         self, app: FastAPI, task

services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_utils_computational.py

@@ -16,9 +16,7 @@
 
 def resources_from_dask_task(task: DaskTask) -> Resources:
     return Resources(
-        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
+        cpus=task.required_resources.get("CPU", _DEFAULT_MAX_CPU),
         ram=task.required_resources.get("RAM", _DEFAULT_MAX_RAM),
     )