Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

RED-5009 pyinfra now truly rejects messages that couldn't be processed by the callback (e.g. inobtainable storage file)

Browse Source
This commit is contained in:
Julius Unverfehrt 2022-08-24 14:52:57 +02:00
parent 71ad2af4eb
commit 7b00edf6fe
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pyinfra/queue/queue_manager.py
View File

@ -120,6 +120,7 @@ class QueueManager(object):
self.logger.info(f"Aborting message processing for delivery_tag {frame.delivery_tag} " self.logger.info(f"Aborting message processing for delivery_tag {frame.delivery_tag} "
f"due to it being redelivered") f"due to it being redelivered")
self._channel.basic_nack(frame.delivery_tag, requeue=False) self._channel.basic_nack(frame.delivery_tag, requeue=False)
return
self.logger.debug(f"Processing {(frame, properties, body)}.") self.logger.debug(f"Processing {(frame, properties, body)}.")
try: try:
@ -138,6 +139,7 @@ class QueueManager(object):
self._channel.basic_ack(frame.delivery_tag) self._channel.basic_ack(frame.delivery_tag)
else: else:
self.logger.info(f"Processed message with delivery_tag {frame.delivery_tag}, declining message") self.logger.info(f"Processed message with delivery_tag {frame.delivery_tag}, declining message")
self._channel.basic_nack(frame.delivery_tag, requeue=False)
except Exception as ex: except Exception as ex:
n_attempts = _get_n_previous_attempts(properties) + 1 n_attempts = _get_n_previous_attempts(properties) + 1