Как установить статус задачи в цепочке сельдерея

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

Request---> 
    [First Task] -> [Second Task] -> [Third Task] 

Parent of third = second 
Parent of second = first

Мне нужно установить статус прикован запроса от каждого из вспомогательных задач (с использованием Ajax для получения статуса). Идентификатор цепочки равен идентификатору [Третьей задачи], поэтому в третьей задаче я могу установить статус цепи, но как установить статус из двух других задач.

источник

2012-11-28 NitinJ

Wjat Вы пытались далеко? – andrefsp

Что вы имеете в виду по статусу? Успех/неудача? – jeorgen

Я попытался использовать current_task.update_status(), но это только устанавливает статус для текущей задачи. Я хочу установить статус [Третья задача] из [Первая задача] и [Вторая задача]. Есть ли способ, с помощью которого я могу получить третий экземпляр задачи из второй задачи (поскольку они принадлежат к одной цепочке) По статусу i означает (Sucess/Failure/Complete/Custom Status с метаданными) – NitinJ

Вы можете сделать

current_app.AsyncResult({task-id}).[status|results]

Где идентификатор задачи является первым, вторым, третьим, задача. Вы также можете использовать celery.inspect, чтобы увидеть, какие задачи в настоящее время планируются или выполняются.

источник

2013-02-05 22:38:34

Как установить статус задачи в цепочке сельдерея

ответ

Смежные вопросы