diff --git a/tjnetwork.py b/tjnetwork.py
index b669e0d..b9730cb 100644
--- a/tjnetwork.py
+++ b/tjnetwork.py
@@ -1314,3 +1314,10 @@ def get_scheme(name: str, schema_name: str) -> dict[str, Any]:
 def get_all_schemes(name: str) -> list[dict[str, Any]]:
     return api.get_all_schemes(name)
 
+############################################################
+# pipe_risk_probability 41
+############################################################
+def get_pipe_risk_probability_now(name: str, pipe_id: str) -> dict[str, float]:
+    return api.get_pipe_risk_probability_now(name, pipe_id)
+
+