问题描述
我有三个相互关联的 Celery 任务。
如果有任何失败,我希望能够再次重试所有三个(作为一个组)。注意我在这里使用 Group 不是作为并行运行的 Celery 任务组,而是作为顺序运行的任务集合。
目前,我们所有的任务都在一个链中,我们会重试单个任务。我想将其中的一些任务分组(可能在一个链中),以便可以重试该组。
task.retry 仅对当前任务重新排队。
我的初步想法如下:
- 有几个独立的排队链
- 一条链有多个子链
以便重新安排失败的组(链)。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)