Ошибка ModuleNotFoundError при попытке запустить Celery workers с версией Django Rest Framework

При запуске докер-контейнера Celery с помощью следующей команды

я вижу следующую ошибку.

$ celery -A zen_api.zen_api worker --loglevel INFO

Мой проект Django имеет такую структуру.

/zen_api
  manage.py
  /zen_api
    /v1
      /app1
      /app2
    __init__.py
    celery.py
    settings.py

Содержимое __init__.py - это

from .celery import app as celery_app

__all__ = ("celery_app",)

и содержимым celery.py является

import os

from celery import Celery

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "zen_api.zen_api.settings")

app = Celery(
    "zen_api.zen_api",
)

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

app.autodiscover_tasks()


@app.task(bind=True, ignore_result=True)
def debug_task(self):
    print(f"Request: {self.request!r}")

Почему я получаю эту ошибку?

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