update run_flow.py

This commit is contained in:
liangxinbing 2025-03-07 01:19:03 +08:00
parent 07b24752b3
commit 9906d957d4

View File

@ -1,21 +1,33 @@
import asyncio
from app.agent import ToolCallAgent
from app.agent.manus import Manus
from app.flow.base import FlowType
from app.flow.flow_factory import FlowFactory
async def run_flow():
agent = ToolCallAgent()
agent = Manus()
while True:
try:
prompt = input("Enter your prompt (or 'exit' to quit): ")
if prompt.lower() == "exit":
print("Goodbye!")
break
flow = FlowFactory.create_flow(
flow_type=FlowType.PLANNING,
agents=agent,
)
result = await flow.execute("Create a web app that shows Japan travel destinations")
print("Processing your request...")
result = await flow.execute(prompt)
print(result)
except KeyboardInterrupt:
print("Goodbye!")
break
if __name__ == "__main__":
asyncio.run(run_flow())