我想使用异步对象重试先前被撤销的任务
worker_1 | [2019-06-27 16:04:23,094: INFO/MainProcess] Discarding revoked task: ...
根据文档,撤销任务的列表存储在工人的内存中,直到工人重新启动之前才清除。
。有其他方法可以取消运行任务而不是撤销它,还是可以以某种方式从已撤销的任务列表中删除任务?
从"死者"带回被撤销的任务是没有意义的。
我建议您做的是:
-
创建一个与被撤销的任务相同的新任务。
-
在任务上使用
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。