mirror of
https://github.com/hanzoai/python-sdk.git
synced 2026-10-23 20:23:00 +00:00
zeekay
fba1c0175e
Converts hanzo-agent from git submodule to regular directory. This enables simpler cross-package refactoring and unified CI/CD. Source: github.com/hanzoai/agent.git (a8d7ec9)
62 lines
1.6 KiB
Python
62 lines
1.6 KiB
Python
import asyncio
|
|
|
|
from agents import Agent, ItemHelpers, Runner, trace
|
|
|
|
"""
|
|
This example shows the parallelization pattern. We run the agent three times in parallel, and pick
|
|
the best result.
|
|
"""
|
|
|
|
spanish_agent = Agent(
|
|
name="spanish_agent",
|
|
instructions="You translate the user's message to Spanish",
|
|
)
|
|
|
|
translation_picker = Agent(
|
|
name="translation_picker",
|
|
instructions="You pick the best Spanish translation from the given options.",
|
|
)
|
|
|
|
|
|
async def main():
|
|
msg = input("Hi! Enter a message, and we'll translate it to Spanish.\n\n")
|
|
|
|
# Ensure the entire workflow is a single trace
|
|
with trace("Parallel translation"):
|
|
res_1, res_2, res_3 = await asyncio.gather(
|
|
Runner.run(
|
|
spanish_agent,
|
|
msg,
|
|
),
|
|
Runner.run(
|
|
spanish_agent,
|
|
msg,
|
|
),
|
|
Runner.run(
|
|
spanish_agent,
|
|
msg,
|
|
),
|
|
)
|
|
|
|
outputs = [
|
|
ItemHelpers.text_message_outputs(res_1.new_items),
|
|
ItemHelpers.text_message_outputs(res_2.new_items),
|
|
ItemHelpers.text_message_outputs(res_3.new_items),
|
|
]
|
|
|
|
translations = "\n\n".join(outputs)
|
|
print(f"\n\nTranslations:\n\n{translations}")
|
|
|
|
best_translation = await Runner.run(
|
|
translation_picker,
|
|
f"Input: {msg}\n\nTranslations:\n{translations}",
|
|
)
|
|
|
|
print("\n\n-----")
|
|
|
|
print(f"Best translation: {best_translation.final_output}")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|