|
|
|
|
@ -267,6 +267,19 @@ async def get_custom_parameters_controller(db_session: DbSession):
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@router.get("/metrics/{simulation_id}", response_model=StandardResponse[list])
|
|
|
|
|
async def get_custom_parameters_controller(db_session: DbSession, simulation_id:UUID):
|
|
|
|
|
"""Get simulation result."""
|
|
|
|
|
results = await calculate_plant_eaf(db_session, simulation_id, 0, 1200, 15000, 0)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
"data": results,
|
|
|
|
|
"status": "success",
|
|
|
|
|
"message": "Simulation result retrieved successfully",
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
airflow_router = APIRouter()
|
|
|
|
|
|
|
|
|
|
@ -373,24 +386,3 @@ async def calculate_contribution(
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# @router.get("/status/{simulation_id}", response_model=StandardResponse[None])
|
|
|
|
|
# async def get_simulation_status(simulation_id: str):
|
|
|
|
|
# """Get simulation status."""
|
|
|
|
|
# if simulation_id not in active_simulations:
|
|
|
|
|
# raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Simulation not found")
|
|
|
|
|
|
|
|
|
|
# return active_simulations[simulation_id]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# @router.post("/cancel/{simulation_id}", response_model=StandardResponse[None])
|
|
|
|
|
# async def cancel_simulation(simulation_id: str):
|
|
|
|
|
# """Cancel simulation."""
|
|
|
|
|
# if simulation_id not in active_simulations:
|
|
|
|
|
# raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Simulation not found")
|
|
|
|
|
|
|
|
|
|
# active_simulations[simulation_id].update({
|
|
|
|
|
# "status": "cancelled",
|
|
|
|
|
# "cancelled_at": datetime.now()
|
|
|
|
|
# })
|
|
|
|
|
|
|
|
|
|
# return active_simulations[simulation_id]
|
|
|
|
|
|