Skip to content

Commit 7d6d885

Browse files
author
Andrei Neagu
committed
removed _models
1 parent 95cd9d5 commit 7d6d885

File tree

4 files changed

+14
-10
lines changed

4 files changed

+14
-10
lines changed

packages/service-library/src/servicelib/long_running_tasks/_lrt_client.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,16 @@
88
from ..logging_errors import create_troubleshootting_log_kwargs
99
from ..logging_utils import log_decorator
1010
from ..rabbitmq._client_rpc import RabbitMQRPCClient
11-
from ._models import RPCErrorResponse
1211
from ._rabbit_namespace import get_rabbit_namespace
1312
from ._serialization import string_to_object
14-
from .models import LRTNamespace, TaskBase, TaskContext, TaskId, TaskStatus
13+
from .models import (
14+
LRTNamespace,
15+
RPCErrorResponse,
16+
TaskBase,
17+
TaskContext,
18+
TaskId,
19+
TaskStatus,
20+
)
1521
from .task import RegisteredTaskName
1622

1723
_logger = logging.getLogger(__name__)

packages/service-library/src/servicelib/long_running_tasks/_lrt_server.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,10 @@
22
from typing import Any
33

44
from ..rabbitmq import RPCRouter
5-
from ._models import RPCErrorResponse
65
from ._serialization import object_to_string
76
from .base_long_running_manager import BaseLongRunningManager
87
from .errors import BaseLongRunningError, TaskNotCompletedError, TaskNotFoundError
9-
from .models import TaskBase, TaskContext, TaskId, TaskStatus
8+
from .models import RPCErrorResponse, TaskBase, TaskContext, TaskId, TaskStatus
109
from .task import RegisteredTaskName
1110

1211
router = RPCRouter()

packages/service-library/src/servicelib/long_running_tasks/_models.py

Lines changed: 0 additions & 6 deletions
This file was deleted.

packages/service-library/src/servicelib/long_running_tasks/models.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,11 @@ class ClientConfiguration(BaseModel):
100100
default_timeout: PositiveFloat
101101

102102

103+
class RPCErrorResponse(BaseModel):
104+
str_traceback: str
105+
error_object: str
106+
107+
103108
@dataclass(frozen=True)
104109
class LRTask:
105110
progress: TaskProgress

0 commit comments

Comments
 (0)