hive-messaging: Avoid "close called on closed connection" errors

gbenson · Sep 25, 2024 · 8db2d9f · 8db2d9f
1 parent c1dba13
commit 8db2d9f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/libs/messaging/hive/messaging/connection.py b/libs/messaging/hive/messaging/connection.py
@@ -11,7 +11,8 @@ def __enter__(self):
         return self
 
     def __exit__(self, *exc_info):
-        self._pika.close()
+        if self._pika.is_open:
+            self._pika.close()
 
     def channel(self, *args, **kwargs):
         """Like :class:pika.channel.Channel` but with different defaults.