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