We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fa2c512 commit 377f6b8Copy full SHA for 377f6b8
packages/celery-library/src/celery_library/rpc/_async_jobs.py
@@ -3,10 +3,6 @@
3
import logging
4
5
from celery.exceptions import CeleryError # type: ignore[import-untyped]
6
-from celery_library.errors import (
7
- TransferrableCeleryError,
8
- decode_celery_transferrable_error,
9
-)
10
from models_library.api_schemas_rpc_async_jobs.async_jobs import (
11
AsyncJobGet,
12
AsyncJobId,
@@ -25,6 +21,11 @@
25
21
from servicelib.logging_utils import log_catch
26
22
from servicelib.rabbitmq import RPCRouter
27
23
24
+from ..errors import (
+ TransferrableCeleryError,
+ decode_celery_transferrable_error,
+)
28
+
29
_logger = logging.getLogger(__name__)
30
router = RPCRouter()
31
0 commit comments