2013-12-12 2 views
-1

Я хочу отменить задачу, ожидающую очереди в сельдерее, но отмена не влияет на состояние задачи. Статус всегда либо PENDING, либо SUCCESS. Пробовал цветок сельдерея, статус задачи либо УСПЕХА, либо НАЧАЛО, показывается, что он не может просмотреть ожидающую задачу. Пытались эти методы отменив задачиКак отменить задачу в очереди сельдерея?

AsyncResult(task_id).revoke 

celery_control = Control() 

celery_control.revoke(task_id) 

from celery.task.control import revoke   
revoke(task_id), terminate=True) 

Заранее спасибо

ответ

0
from celery.task.control import revoke 
revoke(task_id, terminate=True) 
+0

В API изменен в сельдерее 3.1. 'from celery.task.control import revoke' больше не работает. – Rockallite

+0

См. Http://celery.readthedocs.org/en/latest/faq.html#can-i-cancel-the-execution-of-a-task для отзыва задач в Celery 3.1+ – Rockallite

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