|
@@ -125,7 +125,8 @@ def get_tmp_table_name(dag_uuid: str, node_id: str, out_pin: str, db: Session):
|
|
|
if task_id:
|
|
if task_id:
|
|
|
table_name = f'job{job_id}_task{task_id}_subnode{node_id}_output{out_pin}_tmp'
|
|
table_name = f'job{job_id}_task{task_id}_subnode{node_id}_output{out_pin}_tmp'
|
|
|
t_list = hiveDs.list_tables()
|
|
t_list = hiveDs.list_tables()
|
|
|
- if table_name.lower() not in t_list:
|
|
|
|
|
|
|
+ table_name = table_name.lower()
|
|
|
|
|
+ if table_name not in t_list:
|
|
|
raise Exception('该节点不存在中间结果')
|
|
raise Exception('该节点不存在中间结果')
|
|
|
return table_name
|
|
return table_name
|
|
|
else:
|
|
else:
|
