Próbuję napisać niestandardowe polecenie django-admin, które wykonuje zadanie selera, jednak zadanie nie zostanie wykonane, a django po prostu zawiesi się, gdy spróbuję.
from django.core.management.base import BaseCommand
from myapp.tasks import my_celery_task
class Command(BaseCommand):
def handle(self, *args, **options):
print "starting task"
my_celery_task.delay()
print "task has been sent"
Dane wyjściowe, które otrzymuję podczas wywoływania polecenia, to:
starting task
Nigdy nie docieram do linii "zadanie zostało wysłane". Po prostu wisi. Nie jestem pewien, dlaczego zadanie nie działa. Zadania selera są nazywane idealnie, gdy są wywoływane przez widok.
Odpowiedzi:
0 dla odpowiedzi № 1Problem był w rzeczywistości z RabbitMQ na Macu po uaktualnieniu do High Sierra.