[發(fā)明專利]任務(wù)流的調(diào)度方法、裝置、存儲介質(zhì)以及電子裝置

在審

• 申請?zhí)枺?/td>: 202011641926.0
• 申請日: 2020-12-31
• 公開（公告）號: CN112667384A
• 公開（公告）日: 2021-04-16
• 發(fā)明（設(shè)計）人: 劉東東
• 申請（專利權(quán)）人: 青島海爾科技有限公司;海爾智家股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F16/2455
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 趙靜

1.一種任務(wù)流的調(diào)度方法，其特征在于，包括：

獲取調(diào)度器中第一任務(wù)流的執(zhí)行狀態(tài)，其中，所述第一任務(wù)流為第一工程中的任務(wù)流；

在所述第一任務(wù)流的執(zhí)行狀態(tài)表示執(zhí)行完成的情況下，獲取第一任務(wù)流列表，其中，所述第一任務(wù)流表被配置為記錄第二任務(wù)流，所述第二任務(wù)流為除所述第一工程之外的其他工程中的依賴于所述第一任務(wù)流的其他任務(wù)流；

在所述第一任務(wù)流列表中包括所述第二任務(wù)流的情況下，調(diào)用所述調(diào)度器執(zhí)行所述第二任務(wù)流。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在獲取第一任務(wù)流列表之后，所述方法還包括：

在所述第一任務(wù)流列表中不包括所述第二任務(wù)流的情況下，調(diào)用所述調(diào)度器執(zhí)行第三任務(wù)流，其中，所述第三任務(wù)流為在所述第一工程中的執(zhí)行順序處于所述第一任務(wù)流之后的其他任務(wù)流。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在獲取調(diào)度器中第一任務(wù)流的執(zhí)行狀態(tài)之后，所述方法還包括：

在所述執(zhí)行狀態(tài)表示所述第一任務(wù)流執(zhí)行異常的情況下，將所述執(zhí)行異常的第一任務(wù)流確定為第四任務(wù)流；

將所述第四任務(wù)流添加到第二任務(wù)流列表，并將所述第四任務(wù)流保存到集群數(shù)據(jù)庫中。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述方法還包括：

獲取重試配置參數(shù)，所述重試配置參數(shù)中包括輪詢次數(shù)和/或輪詢間隔，所述重試配置參數(shù)與所述第一工程具有對應(yīng)關(guān)系；

基于所述重試配置參數(shù)輪詢所述第二任務(wù)流列表，得到輪詢結(jié)果；

根據(jù)所述輪詢結(jié)果處理所述第二任務(wù)流列表中的任務(wù)流。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)所述輪詢結(jié)果處理所述第二任務(wù)流列表中的任務(wù)流，包括：

在所述第二任務(wù)流列表中包括第四任務(wù)流的情況下，重新調(diào)用所述調(diào)度器執(zhí)行所述第四任務(wù)流；

獲取所述調(diào)度器中正在執(zhí)行的所述第四任務(wù)流的執(zhí)行狀態(tài)；

在所述第四任務(wù)流的執(zhí)行狀態(tài)表示執(zhí)行完成的情況下，獲取第三任務(wù)流列表，其中，所述第三任務(wù)流表被配置為記錄第五任務(wù)流，所述第五任務(wù)流為除所述第一工程之外的其他工程中的依賴于所述第四任務(wù)流的其他任務(wù)流；

在所述第三任務(wù)流列表中包括所述第五任務(wù)流的情況下，調(diào)用所述調(diào)度器中執(zhí)行所述第五任務(wù)流。

6.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)所述輪詢結(jié)果處理所述第二任務(wù)流列表中的任務(wù)流，包括：

在所述第二任務(wù)流列表中包括第四任務(wù)流的情況下，重新調(diào)用所述調(diào)度器執(zhí)行所述第四任務(wù)流；

獲取所述調(diào)度器中正在執(zhí)行的所述第四任務(wù)流的執(zhí)行狀態(tài)；

在所述第四任務(wù)流的執(zhí)行狀態(tài)表示執(zhí)行異常的情況下，獲取所述第四任務(wù)流的重試次數(shù)，其中，所述重試次數(shù)由所述第四任務(wù)流保存到集群數(shù)據(jù)庫的次數(shù)確定；

在所述重試次數(shù)小于等于所述預(yù)定閾值的情況下，繼續(xù)重新執(zhí)行所述第四任務(wù)流，直到所述重試次數(shù)大于預(yù)定閾值；

在所述重試次數(shù)大于預(yù)定閾值的情況下，刪除所述第四任務(wù)流。

7.根據(jù)權(quán)利要求3所述的方法，其特征在于，在將執(zhí)行異常的第一任務(wù)流確定為第四任務(wù)流之后，所述方法還包括：

向預(yù)設(shè)帳號發(fā)送異常指示消息；

響應(yīng)于所述異常指示消息，調(diào)整所述第四任務(wù)流中的任務(wù)，以使得所述第四任務(wù)流中的任務(wù)被允許正常執(zhí)行。

8.一種任務(wù)流的調(diào)度裝置，其特征在于，包括：

第一獲取模塊，用于獲取調(diào)度器中第一任務(wù)流的執(zhí)行狀態(tài)，其中，所述第一任務(wù)流為第一工程中的任務(wù)流；

第二獲取模塊，用于在所述第一任務(wù)流的執(zhí)行狀態(tài)表示執(zhí)行完成的情況下，獲取第一任務(wù)流列表，其中，所述第一任務(wù)流表被配置為記錄第二任務(wù)流，所述第二任務(wù)流為除所述第一工程之外的其他工程中的依賴于所述第一任務(wù)流的其他任務(wù)流；

調(diào)用模塊，用于在所述第一任務(wù)流列表中包括所述第二任務(wù)流的情況下，調(diào)用所述調(diào)度器執(zhí)行所述第二任務(wù)流。