将任务添加到现有组或和弦

Question

考虑以下场景;

有 3 种不同类型的任务。A，B和C。A旨在为B生成输入，B应该在收到来自A的输入后创建许多C任务。

一开始，我只能定义group(A, B)，因为C是由B执行的。但是我想等待所有C任务也完成，以便得出结论，主要任务已经完成。

有没有办法通过使用芹菜实用程序来做到这一点？

Answer 1

到目前为止，我使用的解决方案是等待B内部的C任务。

类似的东西;

from celery.result import allow_join_result
def B():
tasks = get_c_tasks()
g = group(tasks)
gr = g.apply_async()
with allow_join_result():
return gr.join(propagate=False)