2016-09-23 87 views
1

我正在使用Celery運行一些需要很長時間才能完成的任務。 是需要在兩個子任務運行之前完成的初始任務。我創建的任務是文件系統操作,不返回結果。如何使用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)()

你除了運行能夠在同一時間運行多個任務多一個工人芹菜嗎?