diff --git a/api/s41_pipe_risk_probability.py b/api/s41_pipe_risk_probability.py
index a82d38a..94234ea 100644
--- a/api/s41_pipe_risk_probability.py
+++ b/api/s41_pipe_risk_probability.py
@@ -58,8 +58,8 @@ def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
     pipe_risk_probability_geometries = {}
 
     with conn[name].cursor(row_factory=dict_row) as cur:
-        cur.execute(f"select * from gis_pipe")
+        cur.execute(f"select ST_AsGeoJSON(geometry) AS geometry")
         for record in cur:
             print(record['geometry'])
 
-    return pipe_risk_probability_geometries
+    return pipe_risk_probability_geometries
\ No newline at end of file