Comment vérifier l'état d'une tâche dans Celery ?

Question

Comment vérifier si une tâche est en cours d'exécution dans celery (plus précisément, j'utilise celery-django) ?

J'ai lu la documentation, et j'ai cherché sur Google, mais je ne vois pas d'appel comme celui-ci :

my_example_task.state() == RUNNING

Mon cas d'utilisation est que j'ai un service externe (java) pour le transcodage. Lorsque j'envoie un document à transcoder, je veux vérifier si la tâche qui exécute ce service est en cours d'exécution, et si non, la (re)lancer.

J'utilise les versions stables actuelles - 2.4, je crois.

Answer 1

Pour les tâches simples, nous pouvons utiliser http://flower.readthedocs.io/en/latest/screenshots.html y http://policystat.github.io/jobtastic/ pour effectuer le contrôle.

et pour les tâches compliquées, par exemple une tâche qui concerne de nombreux autres modules. Nous recommandons d'enregistrer manuellement la progression et le message sur l'unité de tâche spécifique.

Answer 2

res = method.delay()

print(f"id={res.id}, state={res.state}, status={res.status} ")

print(res.get())