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