|
|
|
|
@ -7,7 +7,7 @@ from sqlalchemy import Delete, Select, func
|
|
|
|
|
from sqlalchemy.orm import selectinload
|
|
|
|
|
|
|
|
|
|
from src.auth.service import CurrentUser
|
|
|
|
|
from src.config import AEROS_BASE_URL
|
|
|
|
|
from src.config import AEROS_BASE_URL, DEFAULT_PROJECT_NAME
|
|
|
|
|
from src.database.core import DbSession
|
|
|
|
|
from src.database.service import search_filter_sort_paginate
|
|
|
|
|
|
|
|
|
|
@ -28,7 +28,7 @@ async def get_all(*, common):
|
|
|
|
|
node.node_name: node for node in results["items"]
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
updateNodeReq = {"projectName": "trialapi", "equipmentNames": reg_nodes}
|
|
|
|
|
updateNodeReq = {"projectName": DEFAULT_PROJECT_NAME, "equipmentNames": reg_nodes}
|
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
response = await client.post(
|
|
|
|
|
@ -127,7 +127,7 @@ async def save_default_equipment(*, db_session: DbSession, project_name: str):
|
|
|
|
|
|
|
|
|
|
reg_nodes = [node.location_tag for node in equipment_nodes.scalars().all()]
|
|
|
|
|
|
|
|
|
|
updateNodeReq = {"projectName": "trialapi", "equipmentNames": reg_nodes}
|
|
|
|
|
updateNodeReq = {"projectName": DEFAULT_PROJECT_NAME, "equipmentNames": reg_nodes}
|
|
|
|
|
|
|
|
|
|
# Delete old data
|
|
|
|
|
query = Delete(AerosEquipment)
|
|
|
|
|
|