如果任何一个失败,如何重试多个 Celery 任务

问题描述

我有三个相互关联的 Celery 任务。

  • 一个发送异步请求。
  • 第二个等待并查询结果。
  • 第三个验证结果。

如果有任何失败,我希望能够再次重试所有三个(作为一个组)。注意我在这里使用 Group 不是作为并行运行的 Celery 任务组,而是作为顺序运行的任务集合。

目前,我们所有的任务都在一个链中,我们会重试单个任务。我想将其中的一些任务分组(可能在一个链中),以便可以重试该组。

task.retry 仅对当前任务重新排队。

我的初步想法如下:

  • 有几个独立的排队链
  • 一条链有多个子链

以便重新安排失败的组(链)。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)