既存のグループまたはコードにタスクを追加

Question

次のシナリオを検討してください。

3種類のタスクがあります。 A,BおよびC。 Aは、Bの入力を生成することを意味し、Bは、Aから入力を受け取った後に多くのCのタスクを作成することになっています。

最初にgroup(A, B)を定義できるのは、CがBであるためです。しかし、私はすべてのCタスクが完了するのを待って、メインタスクが完了したと結論づけたいと思っています。

セロリのユーティリティを使ってこれを行う方法はありますか？

Answer 1

私が今まで使っている解決策は、C内のタスクがBであるのを待っています。

類似のもの;

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)