Agents

from opper_agents import Agent

agent = Agent(name="SimpleAgent")
result = await agent.process("Hello!")

from opper_agents import Agent
from pydantic import BaseModel

class OutputSchema(BaseModel):
    answer: str
    confidence: float

agent = Agent(
    # Identity
    name="MyAgent",
    description="What this agent does",
    instructions="Detailed system prompt...",

    # Tools
    tools=[tool1, tool2],

    # Schemas
    input_schema=InputSchema,    # Optional
    output_schema=OutputSchema,  # Optional

    # Behavior
    max_iterations=25,           # Max think-act cycles
    model="gcp/gemini-flash-latest",  # LLM to use

    # Features
    enable_memory=False,         # Persistent memory
    enable_streaming=False,      # Token streaming

    # Debugging
    verbose=False,               # Print execution
    logger=None,                 # Custom logger

    # Opper config
    opper_api_key=None,          # API key (or use env var)
    opper_base_url=None,         # Custom API endpoint
)

# Simple string input
result = await agent.process("What is 2 + 2?")

# With input schema
result = await agent.process({"question": "What is 2 + 2?"})

# With parent span for tracing
result = await agent.process("What is 2 + 2?", parent_span_id="span-123")

# Single model
agent = Agent(
    name="MyAgent",
    model="gcp/gemini-flash-latest"
)

# Fallback chain (tries in order)
agent = Agent(
    name="MyAgent",
    model=["anthropic/claude-sonnet", "openai/gpt-4o", "gcp/gemini-flash-latest"]
)

agent = Agent(
    name="ResearchAgent",
    description="Researches topics and provides summaries",  # For other agents
    instructions="""You are a thorough research assistant.

When given a topic:
1. Search for relevant information
2. Cross-reference multiple sources
3. Synthesize findings into a clear summary
4. Cite your sources

Always be objective and note any conflicting information."""
)

agent = Agent(
    name="MyAgent",
    max_iterations=10  # Stop after 10 think-act cycles
)

agent = Agent(
    name="MyAgent",
    verbose=True
)

from opper_agents import hook

@hook("agent_end")
async def on_end(context, agent):
    print(f"Total tokens: {context.usage.total_tokens}")
    print(f"Iterations: {context.iteration}")