From 2af3c15267981a361a3c1927eef48c32eeeaf9fb Mon Sep 17 00:00:00 2001
From: Hans Keppens <hans.keppens@gmail.com>
Date: Wed, 20 Nov 2024 17:30:48 +0100
Subject: [PATCH] Let the pipeline know the valves have been updated after
 loading

---
 main.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/main.py b/main.py
index 33c04997..d28cf016 100644
--- a/main.py
+++ b/main.py
@@ -202,6 +202,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}")