new version compatible

HumanStandardInputFlow.py

@@ -53,6 +53,7 @@ class HumanStandardInputFlow(AtomicFlow):
     query_message_prompt_template: JinjaPrompt = None
 
     __default_flow_config = {
+        "_target_": "flow_modules.aiflows.HumanStandardInputFlow.HumanStandardInputFlow.instantiate_from_config",
         "name": "HumanStandardInput",
         "end_of_input_string": "EOI",
         "description": "Reads input from the user's standard input.",

run.py

@@ -42,24 +42,21 @@ if __name__ == "__main__":
     #3. ~~~~ Serve The Flow ~~~~
     serve_utils.serve_flow(
         cl = cl,
-        flow_type="HumanStandardInputFlowModule",
-        default_config=cfg,
-        default_state=None,
-        default_dispatch_point="coflows_dispatch"
+        flow_class_name="flow_modules.aiflows.HumanStandardInputFlowModule.HumanStandardInputFlow",
+        flow_endpoint="HumanStandardInputFlow",
     )
+  
     
     #4. ~~~~~Start A Worker Thread~~~~~
-    run_dispatch_worker_thread(cl, dispatch_point="coflows_dispatch", flow_modules_base_path=FLOW_MODULES_PATH)
+    run_dispatch_worker_thread(cl)
 
     #5. ~~~~~Mount the flow and get its proxy~~~~~~
-    proxy_flow = serve_utils.recursive_mount(
+    proxy_flow= serve_utils.get_flow_instance(
         cl=cl,
-        client_id="local",
-        flow_type="HumanStandardInputFlowModule",
-        config_overrides=None,
-        initial_state=None,
-        dispatch_point_override=None,
-    )   
+        flow_endpoint="HumanStandardInputFlow",
+        user_id="local",
+        config_overrides = cfg
+    )
     
 
     #6. ~~~ Get the data ~~~