How to cancel a task on celery queue?

Question

I want to revoke a task which is pending in celery queue, but the revoke is not making any impact on the task status. The status is either PENDING or SUCCESS always. Tried celery flower the task status is either SUCCESS or STARTED is shown not able view the pending task. Have tried these methods for revoking tasks

AsyncResult(task_id).revoke

celery_control = Control() 

celery_control.revoke(task_id)

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

Thanks in advance

score 4 · Answer 1 · answered Dec 12 '13 at 05:49

4

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

answered Dec 12 '13 at 05:49

Matt Williamson

39,165
10
64
72

The API changed in Celery 3.1. `from celery.task.control import revoke` no longer works. – Rockallite Aug 29 '14 at 03:33
3

See http://celery.readthedocs.org/en/latest/faq.html#can-i-cancel-the-execution-of-a-task for revoking tasks in Celery 3.1+ – Rockallite Aug 29 '14 at 03:40

How to cancel a task on celery queue?

1 Answers1