|
@@ -32,7 +32,7 @@ router = APIRouter(
|
|
|
@sxtimeit
|
|
@sxtimeit
|
|
|
def create_data_management(item: schemas.DataManagementCreate, db: Session = Depends(get_db)):
|
|
def create_data_management(item: schemas.DataManagementCreate, db: Session = Depends(get_db)):
|
|
|
current_time = int(time.time())
|
|
current_time = int(time.time())
|
|
|
- table_name = f'project{g.project_id}_user{item.user_id}_{item.name}_{current_time}'
|
|
|
|
|
|
|
+ table_name = f'project{g.project_id}_user{g.user_id}_{item.name}_{current_time}'
|
|
|
table_name = table_name.lower()
|
|
table_name = table_name.lower()
|
|
|
tmp_table_name = get_tmp_table_name(item.dag_uuid, item.node_id, str(item.out_pin), db)
|
|
tmp_table_name = get_tmp_table_name(item.dag_uuid, item.node_id, str(item.out_pin), db)
|
|
|
af_run_res = data_transfer_run(database_name+'.'+tmp_table_name, database_name+'.'+table_name)
|
|
af_run_res = data_transfer_run(database_name+'.'+tmp_table_name, database_name+'.'+table_name)
|
