|
|
@@ -16,8 +16,8 @@ def datax_create_job(job_info: models.JobInfo, db: Session):
|
|
|
"desc": job_info.job_desc,
|
|
|
"route_strategy": job_info.executor_route_strategy,
|
|
|
"block_strategy": job_info.executor_block_strategy,
|
|
|
- "executor_timeout": job_info.executor_timeout,
|
|
|
- "executor_fail_retry_count": job_info.executor_fail_retry_count,
|
|
|
+ "execution_timeout": job_info.executor_timeout,
|
|
|
+ "retries": job_info.executor_fail_retry_count,
|
|
|
"trigger_status": job_info.trigger_status,
|
|
|
"job_mode":1,
|
|
|
"job_type": 0,
|
|
|
@@ -83,8 +83,8 @@ def datax_update_job(job_info: models.JobInfo, db: Session):
|
|
|
"desc": job_info.job_desc,
|
|
|
"route_strategy": job_info.executor_route_strategy,
|
|
|
"block_strategy": job_info.executor_block_strategy,
|
|
|
- "executor_timeout": job_info.executor_timeout,
|
|
|
- "executor_fail_retry_count": job_info.executor_fail_retry_count,
|
|
|
+ "execution_timeout": job_info.executor_timeout,
|
|
|
+ "retries": job_info.executor_fail_retry_count,
|
|
|
"trigger_status": job_info.trigger_status,
|
|
|
}
|
|
|
res = send_put('/af/af_job', old_af_job['id'], af_job)
|
