Files changed (1) hide show
  1. run.py +4 -4
run.py CHANGED
@@ -9,7 +9,7 @@ from aiflows.utils.general_helpers import read_yaml_file, quick_load_api_keys
9
  from aiflows import logging
10
  from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
11
 
12
- from aiflows.utils import serve_utils
13
  from aiflows.workers import run_dispatch_worker_thread
14
  from aiflows.messages import FlowMessage
15
  from aiflows.interfaces import KeyInterface
@@ -54,7 +54,7 @@ if __name__ == "__main__":
54
 
55
 
56
  #3. ~~~~ Serve The Flow ~~~~
57
- serve_utils.serve_flow(
58
  cl=cl,
59
  flow_class_name="flow_modules.aiflows.ChatFlowModule.ChatAtomicFlow",
60
  flow_endpoint="ChatAtomicFlow",
@@ -64,7 +64,7 @@ if __name__ == "__main__":
64
  run_dispatch_worker_thread(cl)
65
 
66
  #5. ~~~~~Mount the flow and get its proxy~~~~~~
67
- proxy_flow= serve_utils.get_flow_instance(
68
  cl=cl,
69
  flow_endpoint="ChatAtomicFlow",
70
  user_id="local",
@@ -100,6 +100,6 @@ if __name__ == "__main__":
100
 
101
 
102
  #9. ~~~~~Optional: Unserve Flow~~~~~~
103
- # serve_utils.delete_served_flow(cl, "ReverseNumberAtomicFlow_served")
104
 
105
 
 
9
  from aiflows import logging
10
  from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
11
 
12
+ from aiflows.utils import serving
13
  from aiflows.workers import run_dispatch_worker_thread
14
  from aiflows.messages import FlowMessage
15
  from aiflows.interfaces import KeyInterface
 
54
 
55
 
56
  #3. ~~~~ Serve The Flow ~~~~
57
+ serving.serve_flow(
58
  cl=cl,
59
  flow_class_name="flow_modules.aiflows.ChatFlowModule.ChatAtomicFlow",
60
  flow_endpoint="ChatAtomicFlow",
 
64
  run_dispatch_worker_thread(cl)
65
 
66
  #5. ~~~~~Mount the flow and get its proxy~~~~~~
67
+ proxy_flow= serving.get_flow_instance(
68
  cl=cl,
69
  flow_endpoint="ChatAtomicFlow",
70
  user_id="local",
 
100
 
101
 
102
  #9. ~~~~~Optional: Unserve Flow~~~~~~
103
+ # serving.delete_served_flow(cl, "ReverseNumberAtomicFlow_served")
104
 
105