review @sanderegg

Author: matusdrobuliak66

services/director-v2/src/simcore_service_director_v2/api/rpc/_computations.py

@@ -17,17 +17,17 @@
 from models_library.users import UserID
 from servicelib.rabbitmq import RPCRouter
 from servicelib.utils import limited_gather
-from simcore_service_director_v2.models.comp_run_snapshot_tasks import (
-    CompRunSnapshotTaskDBGet,
-)
-from simcore_service_director_v2.modules.db.repositories.comp_runs_snapshot_tasks import (
-    CompRunsSnapshotTasksRepository,
-)
 
 from ...core.errors import ComputationalRunNotFoundError
+from ...models.comp_run_snapshot_tasks import (
+    CompRunSnapshotTaskDBGet,
+)
 from ...models.comp_runs import CompRunsAtDB
 from ...models.comp_tasks import ComputationTaskForRpcDBGet
 from ...modules.db.repositories.comp_runs import CompRunsRepository
+from ...modules.db.repositories.comp_runs_snapshot_tasks import (
+    CompRunsSnapshotTasksRepository,
+)
 from ...modules.db.repositories.comp_tasks import CompTasksRepository
 from ...utils import dask as dask_utils
 

services/director-v2/tests/unit/with_dbs/comp_scheduler/test_scheduler_dask.py

@@ -11,7 +11,6 @@
 
 import asyncio
 import datetime
-from calendar import c
 from collections.abc import AsyncIterator, Awaitable, Callable
 from copy import deepcopy
 from dataclasses import dataclass

services/web/server/src/simcore_service_webserver/director_v2/_computations_service.py

@@ -301,7 +301,6 @@ async def list_computations_latest_iteration_tasks(
 async def _get_root_project_names_v2(
     app: web.Application, items: list[ComputationCollectionRunRpcGet]
 ) -> list[str]:
-    """Resolve root project names from computation items"""
     root_uuids: list[ProjectID] = []
     for item in items:
         if root_id := item.info.get("project_metadata", {}).get(