diff --git a/main.py b/main.py
index e277d3a..7c061ee 100644
--- a/main.py
+++ b/main.py
@@ -209,6 +209,8 @@ async def load_modules_from_directory(directory):
                             }
                             valves = ValvesModel(**combined_valves)
                             pipeline.valves = valves
+                            if hasattr(pipeline, "on_valves_updated"):
+                                await pipeline.on_valves_updated()
 
                             logging.info(f"Updated valves for module: {module_name}")