Fix circular import

sdss · Sep 7, 2024 · 6e9e2a5 · 6e9e2a5
1 parent fa6c4c7
commit 6e9e2a5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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