removed cluster_id

ITISFoundation · Dec 3, 2024 · a529200 · a529200
1 parent 0079662
commit a529200
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git a/services/director-v2/src/simcore_service_director_v2/models/comp_runs.py b/services/director-v2/src/simcore_service_director_v2/models/comp_runs.py
@@ -148,7 +148,7 @@ def convert_null_to_empty_metadata(cls, v):
                     "run_id": 43243,
                     "project_uuid": "65fee9d2-e030-452c-a29c-45d288577ca5",
                     "user_id": 132,
-                    "cluster_id": 123,
+                    "cluster_id": None,
                     "iteration": 12,
                     "result": "SUCCESS",
                     "created": "2021-03-01T13:07:34.191610",

diff --git a/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_manager.py b/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_manager.py
@@ -38,9 +38,7 @@ async def run_new_pipeline(
     run_metadata: RunMetadataDict,
     use_on_demand_clusters: bool,
 ) -> None:
-    """Sets a new pipeline to be scheduled on the computational resources.
-    Passing cluster_id=0 will use the default cluster. Passing an existing ID will instruct
-    the scheduler to run the tasks on the defined cluster"""
+    """Sets a new pipeline to be scheduled on the computational resources."""
     # ensure the pipeline exists and is populated with something
     db_engine = get_db_engine(app)
     dag = await _get_pipeline_dag(project_id, db_engine)

diff --git a/...ces/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_base.py b/...ces/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_base.py
@@ -783,9 +783,9 @@ async def _schedule_tasks_to_start(  # noqa: C901
         except Exception:
             _logger.exception(
                 "Unexpected error for %s with %s on %s happened when scheduling %s:",
-                f"{user_id=}",
-                f"{project_id=}",
-                f"{comp_run.cluster_id=}",
+                f"{comp_run.user_id=}",
+                f"{comp_run.project_uuid=}",
+                f"{comp_run.use_on_demand_clusters=}",
                 f"{tasks_ready_to_start.keys()=}",
             )
             await CompTasksRepository.instance(