Почему celery не получает задание в django?

Я новичок в celery, есть простая задача, которую я хочу использовать celery в Django, но в журнале celery нет никакого сообщения для получения задачи. вот мои коды:

celery.py:

from __future__ import absolute_import, unicode_literals
from celery import Celery


app = Celery('kia', broker='redis://localhost:6379/0')
app.conf.update(
    result_serializer='json',
    accept_content = ['application/json'],
    task_serializer = 'json'        
)
app.autodiscover_tasks()

tasks.py:

import section
.
.
.

logger = get_task_logger('__name__')


@task(name="send_sms_task")
def send_sms_task(text, phone_number):
    logger.info("sms sented")
    return sms(text, phone_number)

views.py:

import section
.
.
.
@api_view(['GET',])
@permission_classes((AllowAny,))
def TestSMS(request):
    if request.method == 'GET':
        x = send_sms_task.apply_async(["something", "somethingelse"])
        data= {"OK"}
        return Response(data)

sms.py:

def send_sms(text,phone_number):
    print("an api service that work correctly")

Наконец, это мой проект дерева:

├── account
│   ├── admin.py
│   ├── apps.py
│   ├── __init__.py
│   ├── migrations
│   ├── models.py
│   ├── permisions.py
│   ├── serializers.py
│   ├── sms.py
│   ├── tasks.py
│   ├── urls.py
│   ├── utils.py
│   └── views.py
├── db.sqlite3
├── project
│   ├── celery.py
│   ├── __init__.py
│   ├── settings.py
│   ├── urls.py
│   └── wsgi.py
├── manage.py

функция в sms.py работает без celery, но когда я пытаюсь использовать celery, ничего не происходит в журнале celery, кроме того, в двух случаях (с celery и без него) я получаю ответ с кодом 200

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