1
Celeryを使用して、完了に時間がかかるタスクを実行しています。そこに は、2つのサブタスクを実行する前に完了する必要のある最初のタスクです。私が作成したタスクはファイルシステムの操作であり、結果は返されません。Celeryで並列タスクを実行するにはどうすればよいですか?
サブタスクを同時に実行したいと思いますが、これらのタスクにグループを使用すると、順次実行され、並列には実行されません。
私が試してみました:
g = group([secondary_task(), secondary_tasks2()])
chain(initial_task(),g)
を私も最初のタスクでグループを直接実行してみたが、それはどちらか動作するようには思えません。
私はセロリで何かを達成しようとしていますか?
First Task
/ \
Second Task Third Task
ない:
First Task
|
Second Task
|
Third Task