如何在运行时撤消任务

Question

当我发送任务并试图撤销

app=Celery()
app.control.revoke(task.id)
#or
app.control.revoke(task.id, terminate=True)

如果我得到错误：

[2019-09-05 05:27:50,110: ERROR/MainProcess] pidbox command error: NotImplementedError("<class 'celery.concurrency.gevent.TaskPool'> does not implement kill_job",)

我用的是gevent

celery -A MyApp worker -l info -P gevent

怎么了？你知道吗

泰

Answer 1

gevent并发不允许终止作业。Pre-fork确实允许这样做，因为它非常简单，只需终止正在运行要终止的任务的工作进程，线程也是如此。你知道吗

有一个关于这个的问题，有一个提议的解决方案-https://github.com/celery/celery/issues/4019-但是没有人做公关