|
|
@@ -27,8 +27,7 @@ def datax_create_job(job_info: models.JobInfo, db: Session):
|
|
|
af_job = res['data']
|
|
|
crud.create_relation(db, job_info.id,'datax', af_job['id'])
|
|
|
send_submit(af_job['id'])
|
|
|
- get_job_last_parsed_time()
|
|
|
- # on_off_control(af_job['id'], job_info.trigger_status)
|
|
|
+ on_off_control(af_job['id'], job_info.trigger_status)
|
|
|
|
|
|
def datax_create_task(job_info: models.JobInfo):
|
|
|
cmd_parameter = get_cmd_parameter(job_info.jvm_param)
|
