Как обновлять задачи Celery в производстве?
У меня есть приложение Django и несколько запланированных задач, обрабатываемых Celery. В качестве брокера сообщений я использую RabbitMQ. Локально все работает как положено, но в продакшене celery worker запускает старые задачи, которые уже даже не существуют. Я пробовал добавить worker restart к моему celery worker Kubernetes-deployment -file, но это ничего не изменило. Вот что я пробовал:
spec:
containers:
- name: celery-worker
command: ["/bin/sh"]
args:
- -c
- >-
celery -A project_name -b 10.0.240.179 worker -l info &&
celery restart -A project_name -b 10.0.240.179 worker -l info
Это запускает рабочий модуль без ошибок, но он все еще использует старые, уже удаленные задачи. Есть ли способ, как я могу получить обновленные задачи из settings.py Django?
Редактирование. Я также попробовал запустить celery multi start 1 -A proj -l info -c4 --pidfile=/var/run/celery/%n.pid внутри моего backend pod, но это тоже ничего не изменило.