Agents

async def astream(self, input: str, *, ctx: Context) -> AsyncIterator[Event]:
    ...

from orxhestra import LlmAgent

agent = LlmAgent(
    name="MyAgent",
    model=model,
    tools=[search_tool, calculator_tool],
    instructions="You are a research assistant.",   # or a Callable[[ReadonlyContext], str]
    description="Searches and calculates things.",
    planner=my_planner,         # optional BasePlanner
    output_schema=MySchema,     # optional: force structured output
    max_iterations=10,
    before_model_callback=None,
    after_model_callback=None,
    before_tool_callback=None,
    after_tool_callback=None,
)

def my_instructions(ctx: ReadonlyContext) -> str:
    user_name = ctx.state.get("user_name", "user")
    return f"You are helping {user_name}. Be concise."

agent = LlmAgent(name="Agent", model=model, instructions=my_instructions)

from orxhestra import ReActAgent

agent = ReActAgent(
    name="ThinkingAgent",
    model=model,
    tools=[search_tool],
    instructions="You are a research assistant. Always cite your sources.",
    max_iterations=10,
)