Skip to content

Commit 1ec6223

Browse files
committed
wrong types
1 parent acb0a93 commit 1ec6223

File tree

1 file changed

+8
-10
lines changed
  • services/autoscaling/src/simcore_service_autoscaling/modules

1 file changed

+8
-10
lines changed

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

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -333,14 +333,12 @@ async def try_retire_nodes(
333333
async def add_instance_generic_resources(
334334
settings: DaskMonitoringSettings, instance: EC2InstanceData
335335
) -> None:
336-
instance_threads = round(instance.available_resources.cpus)
337-
if settings.AUTOSCALING_DASK.DASK_NTHREADS > 0:
336+
instance_threads = round(instance.resources.cpus)
337+
if settings.DASK_NTHREADS > 0:
338338
# this overrides everything
339-
instance_threads = settings.AUTOSCALING_DASK.DASK_NTHREADS
340-
if settings.AUTOSCALING_DASK.DASK_NTHREADS_MULTIPLIER > 1:
341-
instance_threads = (
342-
instance_threads * settings.AUTOSCALING_DASK.DASK_NTHREADS_MULTIPLIER
343-
)
344-
instance.available_resources.generic_resources[
345-
_DASK_WORKER_THREAD_RESOURCE_NAME
346-
] = instance_threads
339+
instance_threads = settings.DASK_NTHREADS
340+
if settings.DASK_NTHREADS_MULTIPLIER > 1:
341+
instance_threads = instance_threads * settings.DASK_NTHREADS_MULTIPLIER
342+
instance.resources.generic_resources[_DASK_WORKER_THREAD_RESOURCE_NAME] = (
343+
instance_threads
344+
)

0 commit comments

Comments
 (0)