Quick Start

import asyncio
from langchain_anthropic import ChatAnthropic
from langchain_core.tools import tool

from orxhestra import LlmAgent, Runner, InMemorySessionService


@tool
def get_weather(city: str) -> str:
    """Get the current weather for a city."""
    return f"The weather in {city} is sunny and 22 degrees."


agent = LlmAgent(
    name="WeatherAgent",
    model=ChatAnthropic(model="claude-opus-4-7"),
    tools=[get_weather],
    instructions="You are a helpful weather assistant.",
)

runner = Runner(
    agent=agent,
    app_name="demo",
    session_service=InMemorySessionService(),
)


async def main():
    async for event in runner.astream(
        user_id="user-1",
        session_id="session-1",
        new_message="What's the weather in Copenhagen and Berlin?",
    ):
        if event.is_final_response():
            print(event.text)


asyncio.run(main())