celery - 撤销功能是否需要额外的 api 调用来阻止队列中的任务执行？

Question

我有一个并发设置为 1 的工作人员和一个进入无限循环 [用于测试] 的任务。我提交了一个任务 T1，工人得到它并开始工作。我提交了另一个任务，它得到了它，由于它仍然忙于 T1，T2 进入队列 [rabbitMQ]。

我试过 T2.revoke() 和 revoke(t2.task_id)

并与检查员核对以查看撤销状态。每件事看起来都不错。但是当我重新启动worker时，它仍然执行T2。

是否需要做任何事情来抑制 T2 的执行？

Answer 1

您可能需要使用持久撤销，请参见此处。