File tree Expand file tree Collapse file tree 5 files changed +18
-12
lines changed
models-library/src/models_library/api_schemas_directorv2
service-library/src/servicelib/rabbitmq/rpc_interfaces/director_v2
api-server/src/simcore_service_api_server/services_rpc
src/simcore_service_director_v2/api/rpc
tests/unit/with_dbs/comp_scheduler Expand file tree Collapse file tree 5 files changed +18
-12
lines changed Original file line number Diff line number Diff line change 11from typing import Annotated
22
33from pydantic import BaseModel , Field
4- from servicelib .rabbitmq import RPCInterfaceError
54
65
76class Error (BaseModel ):
@@ -16,11 +15,3 @@ class ErrorType(BaseModel):
1615
1716class ErrorEnveloped (BaseModel ):
1817 error : ErrorType
19-
20-
21- class BaseRpcError (RPCInterfaceError ):
22- pass
23-
24-
25- class ComputationalTaskMissingError (BaseRpcError ):
26- msg_template = "Computational run not found for project {project_id}"
Original file line number Diff line number Diff line change 1+ from ..._errors import RPCInterfaceError
2+
3+
4+ class BaseRpcError (RPCInterfaceError ):
5+ pass
6+
7+
8+ class ComputationalTaskMissingError (BaseRpcError ):
9+ msg_template = "Computational run not found for project {project_id}"
Original file line number Diff line number Diff line change 11from dataclasses import dataclass
22from functools import partial
33
4- from models_library .api_schemas_directorv2 .errors import ComputationalTaskMissingError
54from models_library .projects import ProjectID
65from servicelib .rabbitmq ._client_rpc import RabbitMQRPCClient
76from servicelib .rabbitmq .rpc_interfaces .director_v2 import computations_tasks
7+ from servicelib .rabbitmq .rpc_interfaces .director_v2 .errors import (
8+ ComputationalTaskMissingError ,
9+ )
810
911from ..exceptions .backend_errors import JobNotFoundError
1012from ..exceptions .service_errors_utils import service_exception_mapper
Original file line number Diff line number Diff line change 22
33from fastapi import FastAPI
44from models_library .api_schemas_directorv2 .computations import TaskLogFileIdGet
5- from models_library .api_schemas_directorv2 .errors import ComputationalTaskMissingError
65from models_library .projects import ProjectID
76from servicelib .rabbitmq import RPCRouter
7+ from servicelib .rabbitmq .rpc_interfaces .director_v2 .errors import (
8+ ComputationalTaskMissingError ,
9+ )
810from simcore_sdk .node_ports_common import data_items_utils
911
1012from ...core .errors import PipelineNotFoundError
Original file line number Diff line number Diff line change 44import pytest
55from faker import Faker
66from models_library .api_schemas_directorv2 .computations import TaskLogFileIdGet
7- from models_library .api_schemas_directorv2 .errors import ComputationalTaskMissingError
87from models_library .projects import ProjectAtDB , ProjectID
98from models_library .projects_state import RunningState
109from servicelib .rabbitmq import RabbitMQRPCClient
1110from servicelib .rabbitmq .rpc_interfaces .director_v2 import (
1211 computations_tasks as rpc_computations_tasks ,
1312)
13+ from servicelib .rabbitmq .rpc_interfaces .director_v2 .errors import (
14+ ComputationalTaskMissingError ,
15+ )
1416from simcore_postgres_database .models .comp_pipeline import StateType
1517from simcore_service_director_v2 .models .comp_pipelines import CompPipelineAtDB
1618from simcore_service_director_v2 .models .comp_runs import CompRunsAtDB
You can’t perform that action at this time.
0 commit comments