v1.1.0
Browse files
run.py
CHANGED
|
@@ -11,7 +11,7 @@ from aiflows.utils.general_helpers import read_yaml_file, quick_load_api_keys
|
|
| 11 |
from aiflows import logging
|
| 12 |
from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
|
| 13 |
|
| 14 |
-
from aiflows.utils import
|
| 15 |
from aiflows.workers import run_dispatch_worker_thread
|
| 16 |
from aiflows.messages import FlowMessage
|
| 17 |
from aiflows.interfaces import KeyInterface
|
|
@@ -43,7 +43,7 @@ if __name__ == "__main__":
|
|
| 43 |
cfg = read_yaml_file(cfg_path)
|
| 44 |
|
| 45 |
#3. ~~~~ Serve The Flow ~~~~
|
| 46 |
-
|
| 47 |
cl = cl,
|
| 48 |
flow_class_name="flow_modules.aiflows.LCToolFlowModule.LCToolFlow",
|
| 49 |
flow_endpoint="LCToolFlow",
|
|
@@ -53,7 +53,7 @@ if __name__ == "__main__":
|
|
| 53 |
run_dispatch_worker_thread(cl)
|
| 54 |
|
| 55 |
#5. ~~~~~Mount the flow and get its proxy~~~~~~
|
| 56 |
-
proxy_flow=
|
| 57 |
cl=cl,
|
| 58 |
flow_endpoint="LCToolFlow",
|
| 59 |
user_id="local",
|
|
@@ -93,4 +93,4 @@ if __name__ == "__main__":
|
|
| 93 |
|
| 94 |
|
| 95 |
#9. ~~~~~Optional: Unserve Flow~~~~~~
|
| 96 |
-
#
|
|
|
|
| 11 |
from aiflows import logging
|
| 12 |
from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
|
| 13 |
|
| 14 |
+
from aiflows.utils import serving
|
| 15 |
from aiflows.workers import run_dispatch_worker_thread
|
| 16 |
from aiflows.messages import FlowMessage
|
| 17 |
from aiflows.interfaces import KeyInterface
|
|
|
|
| 43 |
cfg = read_yaml_file(cfg_path)
|
| 44 |
|
| 45 |
#3. ~~~~ Serve The Flow ~~~~
|
| 46 |
+
serving.serve_flow(
|
| 47 |
cl = cl,
|
| 48 |
flow_class_name="flow_modules.aiflows.LCToolFlowModule.LCToolFlow",
|
| 49 |
flow_endpoint="LCToolFlow",
|
|
|
|
| 53 |
run_dispatch_worker_thread(cl)
|
| 54 |
|
| 55 |
#5. ~~~~~Mount the flow and get its proxy~~~~~~
|
| 56 |
+
proxy_flow= serving.get_flow_instance(
|
| 57 |
cl=cl,
|
| 58 |
flow_endpoint="LCToolFlow",
|
| 59 |
user_id="local",
|
|
|
|
| 93 |
|
| 94 |
|
| 95 |
#9. ~~~~~Optional: Unserve Flow~~~~~~
|
| 96 |
+
# serving.delete_served_flow(cl, "LCToolFlow")
|