终止当前的芹菜任务

Question

我想编写一个方法来取消在Django应用程序中的当前正在运行的芹菜任务，我尝试了几种不同的方法，我发现文档有点混乱。我只是在寻找一个简单的例子。

Answer 1

如果你想获得任务列表，你可以使用

from celery.task.control import inspect 
inspect().active() 

这给出正在处理的活动的任务列表。在那里你可以得到任务的ID。一旦你得到了任务的ID，您可以使用此

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

您可以编写一个函数来自动完成这个撤销它。