Celery незарегистрированная задача с Django и RabbitMq

При реализации Celery с Django и RabbitMq

я получаю следующее сообщение

[2022-04-07 00:05:10,310: ERROR/MainProcess] Received unregistered task of type 'callservices.celery.send_user_mail'.
The message has been ignored and discarded.

Я выполнил все шаги по настройке, которые я показываю ниже в каждом файле в каталоге Django, но я не смог найти проблему.

Почему упоминается, что задание не зарегистрировано?

celery.py

from celery import Celery

from django.core.mail import EmailMultiAlternatives, send_mail

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'callserviceapp.settings')
app = Celery('callserviceapp')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

@app.task()
def send_user_mail(randomNumber, email):
    print("hola")
    subject = 'Some subject'
    body="Some body"
    
    send_mail(subject, body,'xxxxx.ssmtp@gmail.com', [email],fail_silently = False) 
    return 1

init.py

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from celery import app as celery_app

__all__ = ('celery_app',)

setting.py

INSTALLED_APPS = [
    'sslserver',
    'rest_framework',
    'corsheaders',
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'callserviceapp.apps.CallserviceappConfig',
]


CELERY_BROKER_URL = 'amqp://localhost'

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