✨Computational backend: refactoring of dv-2 computational scheduler (…

…Part 2) (ITISFoundation#6711)
pcrespov · Nov 18, 2024 · 1c2cac0 · 1c2cac0
1 parent b735f46
commit 1c2cac0
Show file tree

Hide file tree

Showing 6 changed files with 216 additions and 171 deletions.
diff --git a/packages/models-library/src/models_library/clusters.py b/packages/models-library/src/models_library/clusters.py
@@ -154,7 +154,7 @@ class Config:
 
 
 ClusterID: TypeAlias = NonNegativeInt
-DEFAULT_CLUSTER_ID: Final[NonNegativeInt] = 0
+DEFAULT_CLUSTER_ID: Final[ClusterID] = 0
 
 
 class Cluster(BaseCluster):

diff --git a/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/__init__.py b/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/__init__.py
@@ -16,10 +16,7 @@ async def start_scheduler() -> None:
         with log_context(
             _logger, level=logging.INFO, msg="starting computational scheduler"
         ):
-            app.state.scheduler = scheduler = await _scheduler_factory.create_from_db(
-                app
-            )
-            scheduler.recover_scheduling()
+            app.state.scheduler = await _scheduler_factory.create_from_db(app)
 
     return start_scheduler