Céleri ne retourne pas

Question

Pour une raison quelconque, chaque fois que je crée et lance une nouvelle tâche dans Céleri il y a un problème avec le retour des résultats. La première tâche revient parfaitement, mais pour toutes les tâches ultérieures, le résultat est toujours en attente. J'ai vérifié le journal de Céleri, et il obtient le résultat correct sans erreur, mais il ne peux pas le retourner.

Si elle aide, je suis en cours d'exécution rabbitmq mon back-end.

Answer 1

Eh bien il se trouve que je avais juste besoin de spécifier explicitement un back-end.

Ajout:

CELERY_RESULT_BACKEND = "amqp"

à mon fichier de paramètres semblait tout correctif.

Answer 2

Je suis également obtenir le même problème, même si j'ajoute backend « AMQP ».

Voici mon fichier de configuration de céleri:

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

CELERY_RESULT_BACKEND = "amqp"
CELERY_AMQP_TASK_RESULT_EXPIRES = 18000  # 5 hours.
CELERY_IMPORTS = ("test", )

Mon coquille où se mêlent première fois est réussie et la deuxième fois son accroché. Après quelque temps, si je l'appelle la méthode à nouveau cela fonctionne. Ce modèle ne cesse de répéter.

>>> r = test.add.delay(4, 4)
>>> r.get()
8
>>> r = test.add.delay(4, 4)
>>> r.get()
^C <---------- it was hung here forever, I had to press ^C

>>> r = test.add.delay(4, 4)
>>> r.get()
8