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

raise test exception

Browse Source
This commit is contained in:
Julius Unverfehrt 2023-02-08 13:24:29 +01:00
parent 62d453dbe3
commit 4861d397fa
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pyinfra/queue/queue_manager.py
View File

@ -146,12 +146,12 @@ 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) self._channel.basic_nack(frame.delivery_tag, requeue=True)
except Exception as ex: except Exception as ex:
n_attempts = _get_n_previous_attempts(properties) + 1 n_attempts = _get_n_previous_attempts(properties) + 1
self.logger.warning(f"Failed to process message, {n_attempts} attempts, error: {str(ex)}") self.logger.warning(f"Failed to process message, {n_attempts} attempts, error: {str(ex)}")
self._channel.basic_nack(frame.delivery_tag, requeue=False) self._channel.basic_nack(frame.delivery_tag, requeue=True)
raise ex raise ex
return callback return callback