终止当前的芹菜任务

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)

您可以编写一个函数来自动执行此操作。