2016-09-23 7 views
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 

答えて

0

チェーンは間違いなく正しいアプローチです。

私はこれが動作するように期待:チェーン(initial_task.s()、g)を()

あなたが同時に一つのタスクよりも多くを実行できるように実行している1人のセロリの労働者よりも多くを持っていますか?

関連する問題