Если работник сельдерея тяжело умирает, повторится ли работа?

Question

Есть ли способ для выполнения задания на сельдерей, если сервер, на котором работает рабочий, умирает? Я имею в виду не только подпроцесс, выполняющий эту работу, но весь сервер становится недоступным.

Я пробовал с RabbitMQ и Redis в качестве брокеров. В обоих случаях, если работа в настоящее время обрабатывается, она полностью забыта. Когда рабочий перезагружается, он даже не пытается переработать задание и, глядя на Кролика или Редиса, их очереди пустые. Бэкэнд результата также пуст.

Похоже, что работник хватает сообщение и полагает, что он вернет его обратно, если подпроцесс завершится неудачей, но если рабочий тоже умрет, он не сможет вернуть его обратно.

(да, я работаю в среде, где это происходит больше, чем один раз в год, и я не хочу терять задачи)

Answer 1

Теоретически установить task_acks_late=True следует сделать трюк. (doc)

С брокером Redis задача будет возвращена после visibility_timeout, которая по умолчанию составляет один час. (doc)

С помощью RabbitMQ задача перезагружается, как только Кролик заметил, что рабочий умер.