Catch errors during shutdown to suppress extra errors in Sentry

NeonGeckoCom · Jan 15, 2025 · 4ab9b2c · 4ab9b2c
1 parent 56770c8
commit 4ab9b2c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/neon_mq_connector/consumers/blocking_consumer.py b/neon_mq_connector/consumers/blocking_consumer.py
@@ -158,6 +158,9 @@ def _close_connection(self):
                 raise RuntimeError(f"Connection still open: {self.connection}")
         except pika.exceptions.StreamLostError:
             pass
+        except AttributeError:
+            # This happens regularly during connection close within `pika`
+            pass
         except Exception as e:
             LOG.exception(f"Failed to close connection due to unexpected exception: {e}")
         self._consumer_started.clear()