Celery Beat отправляет работникам несуществующие задания
Я видел много похожих вопросов, но ничего не помогло. Время от времени я получаю следующую ошибку: 'app.tasks.do_some_work'. Когда я проверяю внутри контейнера Django, контейнера Celery Beat или модуля app.tasks контейнера Celery Worker, я не вижу ни одной задачи с таким именем.
Я определяю расписание для периодических задач с помощью celery_app.conf.beat_schedule, и, похоже, все настроено правильно. Я подозреваю, что в прошлом могла существовать задача с таким именем, но она была удалена или переименована. Возможно, она каким-то образом сохранилась
Вот код внутри контейнеров:
from proj.celery import celery_app
@celery_app.task
def do_some_work():
DoSomeWorkUseCase.execute()
return True
Попытка использования:
- Определите CELERY_IMPORTS в настройках