我如何使用异步将被吊销的芹菜任务重试



我想使用异步对象重试先前被撤销的任务

worker_1 | [2019-06-27 16:04:23,094: INFO/MainProcess] Discarding revoked task: ...

根据文档,撤销任务的列表存储在工人的内存中,直到工人重新启动之前才清除。

有其他方法可以取消运行任务而不是撤销它,还是可以以某种方式从已撤销的任务列表中删除任务?

从"死者"带回被撤销的任务是没有意义的。

我建议您做的是:

  1. 创建一个与被撤销的任务相同的新任务。

  2. 在任务上使用update_state(),并指定可以使用两个不同任务(已撤销的任务和新任务(的元数据。例如 tsk.update_state(meta={"job-id": "babadeda123", "client-id": "skynet", "previous-task-id": "64fb925e-86cb-4d29-b4e5-33f41f8416cc"})其中 64FB925E-86CB-4D29-B4E5-33F41F41F8416CC 是被撤销任务的ID。

相关内容

  • 没有找到相关文章

最新更新