Refine

2025-04-20 10:02:20 +08:00
parent 355aff61b9
commit a6ddc9bb0e
1 changed files with 1 additions and 2 deletions
--- a/api/s41_pipe_risk_probability.py
+++ b/api/s41_pipe_risk_probability.py
@@ -68,8 +68,7 @@ def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
    key_geometry = 'geometry'

    with conn[name].cursor(row_factory=dict_row) as cur:
-        #cur.execute(f"select {key_pipeId}, ST_AsGeoJSON(geometry) AS {key_geometry} from gis_pipe")
-        cur.execute(f"select * from gis_pipe")
+        cur.execute(f"select *, ST_AsGeoJSON(geometry) AS {key_geometry} from gis_pipe")

        for record in cur:
            for col in record: