Refine

api/s0_base.py

@@ -259,7 +259,7 @@ def get_region_type(name: str, id: str)->str:
         return type
 
 
-def get_network_pipe_risk_probability_now(name: str) -> dict[str, Any]:
+def get_network_pipe_risk_probability_now(name: str) -> list[dict[str, Any]]:
     pipe_risk_probability_list = []
     with conn[name].cursor(row_factory=dict_row) as cur:
         cur.execute(f"select * from pipe_risk_probability")

main.py

@@ -2211,7 +2211,7 @@ async def fastapi_get_pipe_risk_probability(network: str, pipe_id: str) -> dict[
     return get_pipe_risk_probability(network, pipe_id)
 
 @app.get('/getnetworkpiperiskprobabilitynow/')
-async def fastapi_get_network_pipe_risk_probability_now(network: str) -> dict[str, Any]:
+async def fastapi_get_network_pipe_risk_probability_now(network: str) -> list[dict[str, Any]]:
     return get_network_pipe_risk_probability_now(network)
 
 

tjnetwork.py

@@ -1323,6 +1323,6 @@ def get_pipe_risk_probability_now(name: str, pipe_id: str) -> dict[str, Any]:
 def get_pipe_risk_probability(name: str, pipe_id: str) -> dict[str, Any]:
     return api.get_pipe_risk_probability(name, pipe_id)
 
-def get_network_pipe_risk_probability_now(name: str) -> dict[str, Any]:
+def get_network_pipe_risk_probability_now(name: str) -> list[dict[str, Any]]:
     return api.get_network_pipe_risk_probability_now(name)