Вызов задачи с помощью сельдерея, который находится внутри папки, выдает ошибку.

У меня есть следующий график ритма сельдерея

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
     },
}

Где я ошибся?

0 ответов

Другие вопросы по тегам