Skip to content

Commit 5385359

Browse files
committed
fix imports
1 parent 1d9a5c1 commit 5385359

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

services/director-v2/src/simcore_service_director_v2/api/routes/computations.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@
7070
from ...modules.db.repositories.users import UsersRepository
7171
from ...modules.resource_usage_tracker_client import ResourceUsageTrackerClient
7272
from ...utils import computations as utils
73+
from ...utils.computations_tasks import validate_pipeline
7374
from ...utils.dags import (
7475
compute_pipeline_details,
7576
compute_pipeline_started_timestamp,
@@ -83,7 +84,6 @@
8384
from ..dependencies.database import get_repository
8485
from ..dependencies.rabbitmq import rabbitmq_rpc_client
8586
from ..dependencies.rut_client import get_rut_client
86-
from .computations_tasks import validate_pipeline
8787

8888
_PIPELINE_ABORT_TIMEOUT_S: Final[timedelta] = timedelta(seconds=30)
8989

services/director-v2/src/simcore_service_director_v2/api/routes/computations_tasks.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,11 @@
2121
from servicelib.utils import logged_gather
2222
from starlette import status
2323

24+
from ...core.errors import PipelineTaskMissingError
2425
from ...modules.db.repositories.comp_pipelines import CompPipelinesRepository
2526
from ...modules.db.repositories.comp_tasks import CompTasksRepository
2627
from ...utils import dask as dask_utils
27-
from ...utils.computations_tasks import PipelineTaskMissingError, validate_pipeline
28+
from ...utils.computations_tasks import validate_pipeline
2829
from ..dependencies.database import get_repository
2930

3031
log = logging.getLogger(__name__)

0 commit comments

Comments
 (0)