Задание Django/Celery получено, но ничего не произошло

Я пытаюсь обновить объект базы данных через задачу celery. без задачи celery я могу обновить объект db, но когда я добавляю .delay() и отправляю его в задачу celery, я получаю

Task passenger.tasks.create_circle[3e60c0ee-6da7-4e7c-80c8-663b27b90762] received
child process 116 calling self.run()
child process 5952 calling self.run()

и затем ничего не произошло. Я не могу обновить объект db вообще.

вот мой settings.py

BROKER_URL = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

и вот tasks.py

@shared_task(bind=True)
def create_circle(self, userid):
    print('celery working')
    radius = 500
    user = Passenger.objects.get(id = userid)
    point = user.location
    point.transform(6347)
    poly = point.buffer(radius)
    poly.transform(4326)
    user.circle = poly
    user.save()

есть идеи?

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