Search code examples
pythonceleryamazon-sqs

Celery with SQS broker & dead letter queue


I'm trying to figure out how can I configure celery to move a message once it passed max_retries as configured, to the dead letter queue.

Currently it is deleting (acks) the message once exceeded max_retries.

Is there such an option?


Solution

  • At the moment, as far as I know, this is not possible but soon Celery should be able to do it. You can already test the branch from the PR mentioned in the Celery issue I linked to and see if it works as you expect.