File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
services/director-v2/src/simcore_service_director_v2 Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -59,7 +59,7 @@ class ComputationalBackendSettings(BaseCustomSettings):
5959 ),
6060 ] = 50
6161 COMPUTATIONAL_BACKEND_DASK_CLIENT_ENABLED : bool = True
62- COMPUTATIONAL_BACKEND_DASK_CLIENT_MAX_DISTRIBUTED_CONCURRENCY : Annotated [
62+ COMPUTATIONAL_BACKEND_PER_CLUSTER_MAX_DISTRIBUTED_CONCURRENT_CONNECTIONS : Annotated [
6363 PositiveInt ,
6464 Field (
6565 description = "defines how many concurrent connections to each dask scheduler are allowed accross all director-v2 replicas"
Original file line number Diff line number Diff line change @@ -95,7 +95,7 @@ def _get_semaphore_capacity_from_scheduler(
9595 ** kwargs , # pylint: disable=unused-argument # noqa: ARG001
9696) -> int :
9797 return (
98- scheduler .settings .COMPUTATIONAL_BACKEND_DASK_CLIENT_MAX_DISTRIBUTED_CONCURRENCY
98+ scheduler .settings .COMPUTATIONAL_BACKEND_PER_CLUSTER_MAX_DISTRIBUTED_CONCURRENT_CONNECTIONS
9999 )
100100
101101
You can’t perform that action at this time.
0 commit comments