Celery workers не работает с RabbitMQ после обновления

Описание проблемы

  • У меня есть работающее django приложение, использующее Celery вместе с Mongo и RMQ (3.7.17-management-alpine)
  • Приложение работает на kubernetes кластер Приложение работает нормально в целом
  • Но когда я обновляю Celery (3.1.25) и Kombu (3.0.37) до Celery (4.1.0) и Kombu (4.1.0), я сталкиваюсь со следующей проблемой:
  1. Celery worker pods come up but do not receive the tasks
  2. I have verified that RMQ receives the messages needed to run tasks in celery workers
  3. There is no error in RMQ or celery worker pod
  4. In fact, celery pod mentions that it is connected to RMQ
  5. Strangely, when I restart the RMQ pod after Celery worker pod comes up things become fine
  6. I am able to run the new tasks in celery workers after I restart RMQ pod

Полагаю, что-то случилось с Celery/Kombu/RMQ после обновления до 4.1.0. Код прекрасно работает со старой версией Celery и Kombu.

Может ли кто-нибудь помочь мне в этом?

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