From 0106b4c6cb8581586df172a372f76ad7a9bbbb3e Mon Sep 17 00:00:00 2001 From: Jonas L Date: Tue, 15 Feb 2022 15:40:01 +0100 Subject: [PATCH] fix(analyzer): remove bad attributes in shutdown handler (#1605) Fixes #1278 --- analyzer/libretime_analyzer/message_listener.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/analyzer/libretime_analyzer/message_listener.py b/analyzer/libretime_analyzer/message_listener.py index c00636e6a..92a0fb6d4 100644 --- a/analyzer/libretime_analyzer/message_listener.py +++ b/analyzer/libretime_analyzer/message_listener.py @@ -125,9 +125,9 @@ class MessageListener: # If you try to close a connection that's already closed, you're going to have a bad time. # We're breaking EAFP because this can be called multiple times depending on exception # handling flow here. - if not self._channel.is_closed and not self._channel.is_closing: + if not self._channel.is_closed: self._channel.stop_consuming() - if not self._connection.is_closed and not self._connection.is_closing: + if not self._connection.is_closed: self._connection.close() def graceful_shutdown(self, signum, frame):