v1.1.0

run.py

@@ -11,7 +11,7 @@ from aiflows.utils.general_helpers import read_yaml_file, quick_load_api_keys
 from aiflows import logging
 from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
 
-from aiflows.utils import serve_utils
+from aiflows.utils import serving
 from aiflows.workers import run_dispatch_worker_thread
 from aiflows.messages import FlowMessage
 from aiflows.interfaces import KeyInterface
@@ -57,7 +57,7 @@ if __name__ == "__main__":
 
     
     #3. ~~~~ Serve The Flow ~~~~
-    serve_utils.serve_flow(
+    serving.serve_flow(
         cl = cl,
         flow_class_name="flow_modules.aiflows.VectorStoreFlowModule.ChromaDBFlow",
         flow_endpoint="ChromaDBFlow",
@@ -68,7 +68,7 @@ if __name__ == "__main__":
     
 
     #5 ~~~~~Mount the flow and get its proxy~~~~~~
-    proxy_flow_cdb= serve_utils.get_flow_instance(
+    proxy_flow_cdb= serving.get_flow_instance(
         cl=cl,
         flow_endpoint="ChromaDBFlow",
         user_id="local",
@@ -76,7 +76,7 @@ if __name__ == "__main__":
     )
     
     #3.(2) ~~~~ Serve The Flow ~~~~
-    serve_utils.serve_flow(
+    serving.serve_flow(
         cl = cl,
         flow_class_name="flow_modules.aiflows.VectorStoreFlowModule.VectorStoreFlow",
         flow_endpoint="VectorStoreFlow",
@@ -87,7 +87,7 @@ if __name__ == "__main__":
     run_dispatch_worker_thread(cl)
 
     #5.(2) ~~~~~Mount the flow and get its proxy~~~~~~
-    proxy_flow_vs= serve_utils.get_flow_instance(
+    proxy_flow_vs= serving.get_flow_instance(
         cl=cl,
         flow_endpoint="VectorStoreFlow",
         user_id="local",
@@ -144,4 +144,4 @@ if __name__ == "__main__":
     
     
     #9. ~~~~~Optional: Unserve Flow~~~~~~
-    # serve_utils.delete_served_flow(cl, "FlowModule")
+    # serving.delete_served_flow(cl, "FlowModule")