removed cluster_id

Author: sanderegg

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",

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)

services/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(