webserver調(diào)用submitExecutableFlow執(zhí)行任務(wù):
submitExecutableFlow
判斷queueflow是否滿了脖隶,默認(rèn)大小為100000:
capacity
調(diào)用uploadExecutableFlow
uploadExecutableFlow
"INSERT INTO execution_flows "
+ "(project_id, flow_id, version, status, submit_time, submit_user, update_time) "
+ "values (?,?,?,?,?,?,?)";
更新execution_flows表敏释,將本次提交flow的狀態(tài)設(shè)置為Preparing,后面會(huì)選擇Executor Server來(lái)執(zhí)行:
如果一直處于的Preparing狀態(tài)吓蘑,一般情況下是executor沒(méi)有執(zhí)行并更新該flow成功,因?yàn)闆](méi)有更新Preparing的狀態(tài)坟冲,可以忽略磨镶,前提是任務(wù)可以正常運(yùn)行。
下面是判斷并提交到executor執(zhí)行任務(wù)的代碼:
判斷是否multiple executor 并執(zhí)行