將任務添加到現有的組或和絃

Question

請考慮以下方案;

有3種不同類型的任務。 A，B和C。 A旨在生成B的輸入，B應接收來自A的輸入後創建許多C任務。

在開始，我只能夠定義group(A, B)爲C s由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)