Celery перезапускает одни и те же задачи снова и снова бесконечно, если есть какие-либо проблемы с сервером rabimq/celery в Python

Я искал об этом, но не получил ожидаемого ответа.

Здесь задан такой же вопрос, но он относится к redis, который может быть решен настройкой,

BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 3600*10} # 10 hours

Я пробовал это, но не работает, так как я узнал, что это применимо только к Redis, а для rabitmq мы должны использовать consumer_timeout. Но я не уверен, как мы можем настроить его или как использовать его с настройками rabitmq python/Django.

Я использую amqp==2.6.1, celery==4.2.2, Python 3.8 Django==3.0.4. и конфигурации CELERY_BROKER_TRANSPORT,

CELERY_BROKER_TRANSPORT_OPTIONS = {
    'max_retries': 3,
    'interval_start': 0,
    'interval_step': 0.5,
    'interval_max': 3,
}

Запуск нескольких celery shared_task одновременно. В середине, если rabbitmq не работает или какие-то проблемы с сервером. Я вижу, как celery перезапускает одни и те же задачи снова и снова бесконечно.

Как остановить это повторное бесконечное выполнение задачи celery?

Вернуться на верх