From 9d927c441101731239ae01b9b24a389dad3da364 Mon Sep 17 00:00:00 2001 From: Taras Terletskyi <888784+tropicoo@users.noreply.github.com> Date: Thu, 23 Nov 2023 22:40:12 +0200 Subject: [PATCH] Update RMQ message ack logic --- app_worker/worker/core/callbacks.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/app_worker/worker/core/callbacks.py b/app_worker/worker/core/callbacks.py index 9ba9f30..c6aeef4 100644 --- a/app_worker/worker/core/callbacks.py +++ b/app_worker/worker/core/callbacks.py @@ -18,6 +18,8 @@ class RMQCallbacks: await self._process_incoming_message(message) except Exception: self._log.exception('Critical exception in worker RabbitMQ callback') + if not message.processed: + await message.reject(requeue=False) async def _process_incoming_message(self, message: IncomingMessage) -> None: self._log.info('[x] Received message %s', message.body)