Приложение Django с celery, задачи всегда "PENDING". Как я могу исправить эту ошибку?

У меня следующие настройки сельдерея в settings.py

CELERY_BROKER_URL = "amqp://admin:admin2017@localhost"
CELERY_IMPORTS = ("web.task",)

Когда я использую форму для отправки задачи в celery, я вижу, что состояние всегда находится в состоянии ожидания

Экранная шапка незавершенных задач

в моделях используется следующий код (у меня также есть tasks.py)

class AnaysisStatus(models.IntegerChoices): 
    PENDING = 1
    COMPLETED = 2
    FAILED = 0

    
class Analysis(models.Model):
    STATUS_CHOICES = ((1,"PENDING"),(2,"COMPLETED"),(0,"FAILED"))
    user = models.ForeignKey(User,on_delete=models.CASCADE)
    status = models.IntegerField(choices=AnaysisStatus.choices,null= True)
    created_at = models.DateTimeField(auto_now_add=True,null=True)
    file = models.FileField(null=True)
    data  = models.JSONField(null=True)

Я очень новичок в celery и django, поэтому любая помощь будет высоко оценена.

Примечание: Я даже не уверен, нужно ли мне устанавливать брокер локально на данный момент amqp похож на RabitMQ? Если да, то я планирую развернуть это в Google Cloud без необходимости использовать google tasks, если это имеет значение.

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