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 f88a41f commit 75d0c06Copy full SHA for 75d0c06
services/director-v2/src/simcore_service_director_v2/modules/dask_client.py
@@ -141,7 +141,7 @@ async def _connect_with_gateway_and_create_cluster(
141
assert cluster # nosec
142
logger.info("Cluster dashboard available: %s", cluster.dashboard_link)
143
# NOTE: we scale to 1 worker as they are global
144
- await cluster.scale(1)
+ await cluster.adapt(active=True)
145
client = await cluster.get_client()
146
assert client # nosec
147
return DaskSubSystem(client, gateway, cluster)
0 commit comments