Django - Celery не может найти мои задачи. Как я могу настроить эту структуру проекта?

Я получаю KeyError: 'example_app.tasks.example_task' всякий раз, когда пытаюсь выполнить задачу (example_task.delay())

Структура проекта:

|-- config
|   |-- celery.py
|   |-- settings.py
|    
|-- src
    |-- example_app
    |    |-- tasks.py
    |
    |-- example_app2
         |-- tasks.py

celery.py

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings')
app = Celery('config')

app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

example_app -> tasks.py

from config.celery import app

@app.task
def example_task():
    print('task')
    return

Я пробовал добавить список в app.autodiscover_tasks(), например ['example_app'] или ['src.example_app'], но не могу заставить его зарегистрироваться. Спасибо

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