We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1f5f0fa commit 619cabfCopy full SHA for 619cabf
services/autoscaling/src/simcore_service_autoscaling/modules/cluster_scaling/_utils_computational.py
@@ -32,15 +32,6 @@ def resources_from_dask_task(task: DaskTask) -> Resources:
32
return Resources.from_flat_dict(
33
{_DASK_TO_RESOURCE_NAME_MAPPING.get(k, k): v for k, v in task_resources.items()}
34
)
35
- # ({
36
- # "cpus": task.required_resources.get("CPU", _DEFAULT_MAX_CPU),
37
- # "ram": task.required_resources.get("RAM", _DEFAULT_MAX_RAM),
38
- # }
39
- # )
40
- # return Resources(
41
- # cpus=task.required_resources.get("CPU", _DEFAULT_MAX_CPU),
42
- # ram=ByteSize(task.required_resources.get("RAM", _DEFAULT_MAX_RAM)),
43
44
45
46
def get_task_instance_restriction(task: DaskTask) -> str | None:
0 commit comments