批次運算服務支援一個作業包含多個任務,任務之間可以有 DAG 依賴關係。
即前面的任務運行完成(Finished
)後, 後面的任務才開始運行。
樣本一
在 job description json 中這樣描述:
{
"Name": "my-job",
"DAG": {
...
"Dependencies": {
"split": ["count"],
"count": ["merge"]
}
}
}
split運行完成後,count開始運行,count完成後,merge才開始運行。
merge運行完成,整個作業結束。
執行個體二
在 job description json 中這樣描述:
{
"Name": "my-job",
"DAG": {
...
"Dependencies": {
"split": ["count1","count2"],
"count1": ["merge"],
"count2": ["merge"]
}
}
}
split 運行完成後,count1 和 count2 同時開始運行,count1 和 count2 都完成後,merge 才開始運行。
merge 運行完成,整個作業結束。