missing constant

Author: sanderegg

services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_dask.py

@@ -52,6 +52,9 @@
     CompRunsRepository,
 )
 from ..db.repositories.comp_tasks import CompTasksRepository
+from ._constants import (
+    MAX_CONCURRENT_PIPELINE_SCHEDULING,
+)
 from ._scheduler_base import BaseCompScheduler
 from ._utils import (
     WAITING_FOR_START_STATES,
@@ -313,7 +316,7 @@ async def _process_completed_tasks(
                     )
                     for task, result in zip(tasks, tasks_results, strict=True)
                 ),
-                limit=10,
+                limit=MAX_CONCURRENT_PIPELINE_SCHEDULING,
             ):
                 with log_catch(_logger, reraise=False):
                     task_can_be_cleaned, job_id = await future