Вызов задачи с помощью сельдерея, который находится внутри папки, выдает ошибку.
У меня есть следующий график ритма сельдерея
CELERY_BEAT_SCHEDULE = {
'task-number-one': {
'task': 'frontend.tasks2.tasks.test_task', #this doesn't work throws following error
'schedule': 1.0
},
}
и следующая ошибка возникает, когда я начинаю бить сельдерея и работника
[2018-08-20 19:26:31,606: ОШИБКА /MainProcess] Получено незарегистрированное задание типа 'frontend.tasks2.tasks.test_task'. Сообщение было проигнорировано и отклонено.
Помните ли вы импортировать модуль, содержащий эту задачу? Или, может быть, вы используете относительный импорт?
У меня есть следующая структура проекта
frontend
|-tasks2
| |-tasks.py
| |-test_task()
|-tasks.py
|-test_task()
Но если я изменю график ритма на следующий, он начинает работать, оба test_task()
функции одинаковы.
CELERY_BEAT_SCHEDULE = {
'task-number-one': {
'task': 'frontend.tasks.test_task', # this does work properly
'schedule': 1.0
},
}
Где я ошибся?