Home Explore Help
Register Sign In
sxwl_DL
/
datax-admin
1
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Browse Source

res

liweiquan 2 years ago
parent
9cf55e9532
commit
ed740ba4db
3 changed files with 3 additions and 3 deletions
Split View Show Diff Stats
  1. 1 1
      app/services/dag.py
  2. 1 1
      app/services/datax.py
  3. 1 1
      app/services/jm_job.py

+ 1 - 1
app/services/dag.py
View File 

@@ -93,7 +93,7 @@ def dag_job_submit(dag_uuid:str,dag_script: str,db: Session):
 
         af_job = dag_create_job(dag_uuid, dag_script, db)
 
     else:
 
         af_job = dag_update_job(dag_uuid, dag_script, db)
 
-    get_job_last_parsed_time(af_job['id'])
 
+    res = get_job_last_parsed_time(af_job['id'])
 
     current_time = res['data']['last_parsed_time'] if 'last_parsed_time' in res['data'].keys() else None
 
     send_submit(af_job['id'])
 
     for i in range(0,21):

+ 1 - 1
app/services/datax.py
View File 

@@ -127,7 +127,7 @@ def on_off_control(af_job_id: int,status: int):
 
         time.sleep(2)
 
 
 def execute_job(af_job_id: int):
 
-    get_job_last_parsed_time(af_job_id)
 
+    res = get_job_last_parsed_time(af_job_id)
 
     current_time = res['data']['last_parsed_time'] if 'last_parsed_time' in res['data'].keys() else None
 
     send_submit(af_job_id)
 
     for i in range(0,21):

+ 1 - 1
app/services/jm_job.py
View File 

@@ -222,7 +222,7 @@ def on_off_control(af_job_id: int,status: int):
 
         time.sleep(2)
 
 
 def execute_job(af_job_id: int):
 
-    get_job_last_parsed_time(af_job_id)
 
+    res = get_job_last_parsed_time(af_job_id)
 
     current_time = res['data']['last_parsed_time'] if 'last_parsed_time' in res['data'].keys() else None
 
     send_submit(af_job_id)
 
     for i in range(0,21):