From 6e9e2a530d05eb84124758cb427658fdf45fcab7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jos=C3=A9=20S=C3=A1nchez-Gallego?= Date: Sat, 7 Sep 2024 22:35:12 +0000 Subject: [PATCH] Fix circular import --- src/gort/pubsub.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/gort/pubsub.py b/src/gort/pubsub.py index 49857b7..3b2dafa 100644 --- a/src/gort/pubsub.py +++ b/src/gort/pubsub.py @@ -33,7 +33,6 @@ from gort import config from gort.enums import Event -from gort.exceptions import GortWarning if TYPE_CHECKING: @@ -216,6 +215,8 @@ async def publish(self, message: dict, routing_key: str | None = None): except AMQPConnectionError: await self.connect() except Exception as err: + from gort.exceptions import GortWarning + warnings.warn(f"Unexpected error in GortPublisher: {err}", GortWarning) break