From 8db2d9f62de2df8d5a36f39c877b75b28ffa3703 Mon Sep 17 00:00:00 2001 From: Gary Benson Date: Wed, 25 Sep 2024 19:40:09 +0100 Subject: [PATCH] hive-messaging: Avoid "close called on closed connection" errors --- libs/messaging/hive/messaging/connection.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/libs/messaging/hive/messaging/connection.py b/libs/messaging/hive/messaging/connection.py index 771c9de..e0c1bb1 100644 --- 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.