Почему задача celery не может создать запись в базе данных django postgres?

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

api/tasks.py

from celery import shared_task
from .models.event import Event

@shared_task
def testTask():
    Event.objects.create(name='test')
    return ''

api/views/test.py

from api.tasks import testTask

@api_view(['GET'])
@authentication_classes([])
@permission_classes([])
def test(request):
    testTask.delay();
    return Response(status=status.HTTP_200_OK, data='ok')

api/celery.py

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'api.settings')

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

api/settings.py

CELERY_BROKER_URL = 'amqp://localhost'

Если запустить только testTask() без функции задержки, то все работает. Не могли бы вы мне помочь? Спасибо!

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