Skip to content

Commit c295e65

Browse files
committed
ensure thread is at least 1
1 parent 87fe39e commit c295e65

File tree

1 file changed

+2
-2
lines changed
  • services/autoscaling/src/simcore_service_autoscaling/modules

1 file changed

+2
-2
lines changed

services/autoscaling/src/simcore_service_autoscaling/modules/dask.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -347,7 +347,7 @@ async def try_retire_nodes(
347347
def add_instance_generic_resources(
348348
settings: DaskMonitoringSettings, instance: EC2InstanceData
349349
) -> None:
350-
instance_threads = round(instance.resources.cpus)
350+
instance_threads = min(1, round(instance.resources.cpus))
351351
if settings.DASK_NTHREADS > 0:
352352
# this overrides everything
353353
instance_threads = settings.DASK_NTHREADS
@@ -365,7 +365,7 @@ def add_instance_generic_resources(
365365
def add_instance_type_generic_resource(
366366
settings: DaskMonitoringSettings, instance_type: EC2InstanceType
367367
) -> None:
368-
instance_threads = round(instance_type.resources.cpus)
368+
instance_threads = min(1, round(instance_type.resources.cpus))
369369
if settings.DASK_NTHREADS > 0:
370370
# this overrides everything
371371
instance_threads = settings.DASK_NTHREADS

0 commit comments

Comments
 (0)