From 02b7edcf1c2502468c5a4a6815a17ed4ce6954a9 Mon Sep 17 00:00:00 2001 From: "martynas.karobcikas" Date: Wed, 10 Dec 2025 14:32:19 +0200 Subject: [PATCH] bugfix: handling when success properties not set --- emf/common/integrations/rabbit.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/emf/common/integrations/rabbit.py b/emf/common/integrations/rabbit.py index 9104e03..0a7e836 100644 --- a/emf/common/integrations/rabbit.py +++ b/emf/common/integrations/rabbit.py @@ -262,7 +262,7 @@ def _process_messages(self, basic_deliver, properties, body): try: logger.info(f"Handling message with handler: {message_handler.__class__.__name__}") body, properties = message_handler.handle(body, properties=properties, channel=None) - if not properties.headers['success']: # stop processing next handlers if message success was set to false + if not properties.headers.get('success', True): # stop processing next handlers if message success was set to false break except Exception as error: @@ -582,7 +582,7 @@ def _process_messages(self, basic_deliver, properties, body): for message_handler in self.message_handlers: logger.info(f"Handling message with handler: {message_handler.__class__.__name__}") body, properties = message_handler.handle(body, properties=properties, channel=self._channel) - if not properties.headers['success']: # stop processing next handlers if message success was set to false + if not properties.headers.get('success', True): # stop processing next handlers if message success was set to false break except Exception as error: logger.error(f"Message handling failed: {error}", exc_info=True)