|
|
@@ -97,6 +97,7 @@ def dag_job_submit(dag_uuid:str,dag_script: str,db: Session):
|
|
|
res = get_job_last_parsed_time(af_job['id'])
|
|
|
last_parsed_time = res['data']['last_parsed_time']
|
|
|
if last_parsed_time and current_time < int(last_parsed_time):
|
|
|
+ send_pause(af_job['id'],1)
|
|
|
send_execute(af_job['id'])
|
|
|
print(f"{af_job['id']}<==执行成功==>{last_parsed_time}")
|
|
|
break
|
