RED-4653: Added re-raising of a caught exception druing message processing to prevent infinite re-tries

2022-07-18 14:02:35 +02:00 · 2022-07-18 14:02:35 +02:00 · ebbaf6f05b
commit ebbaf6f05b
parent 33b26527dc
1 changed files with 2 additions and 1 deletions
--- a/pyinfra/queue/queue_manager.py
+++ b/pyinfra/queue/queue_manager.py
@ -82,7 +82,8 @@ class QueueManager(object):
                self._channel.basic_ack(frame.delivery_tag)
            except Exception as ex:
                n_attempts = _get_n_previous_attempts(properties) + 1
-                logger.warning(f"Message failed to process, {n_attempts} attempts, error {str(ex)}: message: {body}")
+                logger.warning(f"Failed to process message, {n_attempts} attempts, error: {str(ex)}")
+                raise ex

        return callback