wrap workflow.run with asyncio.run

Signed-off-by: Akihiko Kuroda <[email protected]>

maestro/cli/commands.py

@@ -13,6 +13,7 @@
 # limitations under the License.
 
 import os, yaml, json, jsonschema, traceback
+import asyncio
 
 from openai import OpenAI
 from jsonschema.exceptions import ValidationError, SchemaError
@@ -171,7 +172,7 @@ def __init__(self, args):
     def __run_agents_workflow(self, agents_yaml, workflow_yaml):
         try:
             workflow = Workflow(agents_yaml, workflow_yaml[0])
-            workflow.run()
+            asyncio.run(workflow.run())
         except Exception as e:
             self._check_verbose()
             raise RuntimeError("Unable to run workflow: {message}".format(message=str(e)))

maestro/deployments/api.py

@@ -4,6 +4,7 @@
 import json
 import sys
 import io
+import asyncio
 
 import yaml
 from src.workflow import Workflow
@@ -27,7 +28,7 @@ def process_workflow():
 
         output = io.StringIO()
         sys.stdout = output
-        workflow_instance.run()
+        asyncio.run(workflow_instance.run())
         sys.stdout = sys.__stdout__
 
         response = {