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 96407c6 commit aa3df6eCopy full SHA for aa3df6e
services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_dask.py
@@ -90,14 +90,14 @@ def _get_semaphore_cluster_redis_key(
90
return f"{APP_NAME}-cluster-user_id_{user_id}-wallet_id_{run_metadata.get('wallet_id')}"
91
92
93
-@asynccontextmanager
94
@with_limited_concurrency_cm(
95
_get_redis_client_from_scheduler,
96
key=_get_semaphore_cluster_redis_key,
97
capacity=_DASK_CLUSTER_CLIENT_SEMAPHORE_CAPACITY,
98
blocking=True,
99
blocking_timeout=None,
100
)
+@asynccontextmanager
101
async def _cluster_dask_client(
102
user_id: UserID,
103
scheduler: "DaskScheduler",
0 commit comments