|
|
@@ -206,7 +206,7 @@ def get_airflow_dagrun_task_log(job_id: int, af_run_id: str, task_id: str, db: S
|
|
|
state_ret = call_airflow_api(method='get', uri=state_uri, args_dict={})
|
|
|
log_ret = call_airflow_api(method='get', uri=log_uri, args_dict={})
|
|
|
if state_ret.status_code != 200 or log_ret.status_code != 200:
|
|
|
- raise Exception('cant found the information of this task,please check your input ')
|
|
|
+ raise Exception(f'cant found the information of this task,please check your input.log uri is {log_uri} ')
|
|
|
update_run = schemas.AirflowRunUpdate(
|
|
|
**{"details": run.details, "status": run.status, "af_run_id": af_run_id})
|
|
|
task_info = {
|
luoyulong