chore: comments

pipelines/examples/anthropic_manifold_pipeline.py

@@ -48,6 +48,7 @@ class Pipeline:
         pass
 
     async def on_valves_update(self):
+        # This function is called when the valves are updated.
         self.client = Anthropic(api_key=self.valves.ANTHROPIC_API_KEY)
         pass
 

pipelines/examples/applescript_pipeline.py

@@ -18,13 +18,13 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
 
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/azure_openai_pipeline.py

@@ -14,12 +14,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/cohere_manifold_pipeline.py

@@ -40,6 +40,8 @@ class Pipeline:
         pass
 
     async def on_valves_update(self):
+        # This function is called when the valves are updated.
+
         self.pipelines = self.get_cohere_models()
 
         pass

pipelines/examples/example_pipeline.py

@@ -14,12 +14,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/filter_pipeline.py

@@ -34,12 +34,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/haystack_pipeline.py

@@ -75,7 +75,7 @@ class Pipeline:
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         pass
 
     def pipe(

pipelines/examples/langfuse_filter_pipeline.py

@@ -51,18 +51,20 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         self.set_langfuse()
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         self.langfuse.flush()
         pass
 
     async def on_valves_update(self):
+        # This function is called when the valves are updated.
+
         self.set_langfuse()
         pass
 

pipelines/examples/litellm_manifold_pipeline.py

@@ -29,16 +29,18 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 
     async def on_valves_update(self):
+        # This function is called when the valves are updated.
+
         self.pipelines = self.get_litellm_models()
         pass
 

pipelines/examples/litellm_subprocess_manifold_pipeline.py

@@ -38,7 +38,7 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
 
         # Check if the config file exists
@@ -67,12 +67,14 @@ class Pipeline:
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         await self.shutdown_litellm_background()
         pass
 
     async def on_valves_update(self):
+        # This function is called when the valves are updated.
+
         print(f"on_valves_update:{__name__}")
 
         with open(self.valves.LITELLM_CONFIG_DIR, "r") as file:

pipelines/examples/llama_cpp_pipeline.py

@@ -15,7 +15,7 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         from llama_cpp import Llama
 
@@ -29,7 +29,7 @@ class Pipeline:
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/llamaindex_ollama_github_pipeline.py

@@ -66,7 +66,7 @@ class Pipeline:
         print(self.index)
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         pass
 
     def pipe(

pipelines/examples/llamaindex_ollama_pipeline.py

@@ -18,7 +18,7 @@ class Pipeline:
         )
         Settings.llm = Ollama(model="llama3")
 
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         global documents, index
 
         self.documents = SimpleDirectoryReader("./data").load_data()
@@ -26,7 +26,7 @@ class Pipeline:
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         pass
 
     def pipe(

pipelines/examples/llamaindex_pipeline.py

@@ -17,11 +17,11 @@ class Pipeline:
 
         self.documents = SimpleDirectoryReader("./data").load_data()
         self.index = VectorStoreIndex.from_documents(self.documents)
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         pass
 
     def pipe(

pipelines/examples/manifold_pipeline.py

@@ -30,12 +30,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/ollama_manifold_pipeline.py

@@ -28,13 +28,13 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         self.pipelines = self.get_ollama_models()
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/ollama_pipeline.py

@@ -14,12 +14,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/openai_pipeline.py

@@ -14,12 +14,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/python_code_pipeline.py

@@ -11,12 +11,12 @@ class Pipeline:
         pass
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass
 

pipelines/examples/rate_limit_filter_pipeline.py

@@ -47,12 +47,12 @@ class Pipeline:
         self.user_requests = {}
 
     async def on_startup(self):
-        # This function is called when the server is started or after valves are updated.
+        # This function is called when the server is started.
         print(f"on_startup:{__name__}")
         pass
 
     async def on_shutdown(self):
-        # This function is called when the server is stopped or before valves are updated.
+        # This function is called when the server is stopped.
         print(f"on_shutdown:{__name__}")
         pass