Как проверить статус задачи в Celery?

Question

Как проверить статус задачи в Celery?

Как проверить, запущена ли задача в celery (в частности, я использую celery-django)?

Я читал документацию и гуглил, но не могу найти вызов вроде:

my_example_task.state() == RUNNING

Мой случай использования заключается в том, что у меня есть внешний (java) сервис для транскодирования. Когда я отправляю документ на транскодирование, я хочу проверить, запущена ли задача, которая запускает эту службу, и если нет, то (повторно) запустить ее.

Я использую текущие стабильные версии - 2.4, я полагаю.

85

python web-services celery django-celery

задан Marcin 27 January 2012 в 13:49

1 ответ

Другие вопросы по тегам:

python web-services celery django-celery

Похожие вопросы:

score 0 · Answer 1

FirstпјЊin Ваш сельдерей APPпјљ

vi my_celery_apps/app1.py

app = Celery(worker_name)

и затем, измените на задачу fileпјЊimport приложение от своего модуля приложения сельдерея.

vi tasks/task1.py

from my_celery_apps.app1 import app

app.AsyncResult(taskid)

try:
   if task.state.lower() != "success":
        return
except:
    """ do something """