セロリを使用した私のワークフローは次のとおりです。
group1 = (task1, task2)
chain2 = (task3, group1)
group3 = (task4, task5, chain2)
を開始するgroup3
と、すべてがうまくいきます。すべてのタスクは、必要な「依存関係」で実行されます。タスクは何らかの操作を実行し、ブール値を返します。すべてのタスクの結果を確認したいと思います。残念ながら、すべての結果を取得することはできません:
group3.results
戻り値:
True, True, tuple
タプルは次のようなものです。
('8a8b7c2c-db44-4096-ba29-93ad2cd63409', [('576966ec-0ce5-4d82-9ab5-a23da805299b', None), ('777c77a3-34d6-4021-943f-8c39e7e87311', None)])
そして、それを連鎖的な結果のように処理することはできません。id で asyncresult を作成すると8a8b7c2c-db44-4096-ba29-93ad2cd63409
、グループ内のサブタスクの結果にのみアクセスできます (つまり、結果を取得task1
しtask2
ますが、結果を取得する方法はありませんtask3
)。
この方法は非常に複雑ですが、単純なグループ/チェーンの結果を取得するためのすべての方法を見つけたセロリのドキュメントに特定のものが見つかりません。
私はワークフローを本当に知っているという事実を考えると、すべての結果にアクセスするための最良の方法は何ですか?