Celery Worker отключается, но продолжает выполнять задание

У меня есть 8 рабочих в celery, все они работают на разных машинах и выполняют очень длительные задачи (несколько часов)

Эти задачи могут быть остановлены с помощью app.control.revoke(task_id, terminate=True) и видны в app.control.instpect()

Что происходит: определенный порядок событий приводит к тому, что рабочие отсоединяются от RabbitMQ и больше не видны в методе app.control.instpect(), но основной код продолжает выполняться в рабочем.

Эти задачи также не могут быть завершены. Что может привести к подобному?

Есть ли способ предотвратить это отключение? И что может вызвать подобное?

Рабочий запускается с celery -A project worker -l info -P eventlet --concurrency 5 > /dev/null

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