AutoGen: AgentChat, Teams, Termination and Tools Reference Guide

# v0.4+ layered packages — install what you need
pip install -U "autogen-agentchat"               # high-level multi-agent API
pip install -U "autogen-core"                    # actor model primitives
pip install -U "autogen-ext[openai]"             # provider extension (openai, anthropic, ollama, ...)
pip install -U "autogen-ext[docker]"             # sandboxed code-execution

# Studio (visual builder, optional)
pip install -U "autogenstudio"
autogenstudio ui --port 8081

# env — pick the provider matching your extension
export OPENAI_API_KEY=sk-...
export ANTHROPIC_API_KEY=sk-...

import asyncio
from autogen_agentchat.agents import AssistantAgent
from autogen_agentchat.ui import Console
from autogen_ext.models.openai import OpenAIChatCompletionClient

def get_weather(city: str) -> str:
    """Look up current weather for a city."""
    return f"{city}: 22 C, clear."

async def main() -> None:
    model = OpenAIChatCompletionClient(model="gpt-4o-mini")
    agent = AssistantAgent(
        name="weather_bot",
        model_client=model,
        tools=[get_weather],
        system_message="Use tools when the user asks about weather.",
        reflect_on_tool_use=True,
    )
    # Console wraps run_stream and prints to stdout.
    await Console(agent.run_stream(task="What's the weather in Paris?"))
    await model.close()

asyncio.run(main())

import asyncio
from autogen_agentchat.agents import AssistantAgent
from autogen_agentchat.teams import RoundRobinGroupChat
from autogen_agentchat.conditions import TextMentionTermination, MaxMessageTermination
from autogen_agentchat.ui import Console
from autogen_ext.models.openai import OpenAIChatCompletionClient

async def main() -> None:
    model = OpenAIChatCompletionClient(model="gpt-4o-mini")

    writer = AssistantAgent("writer", model, system_message="Draft concise posts.")
    editor = AssistantAgent(
        "editor", model,
        system_message="Critique drafts. When the post is ready, reply with 'APPROVE'.",
    )

    termination = TextMentionTermination("APPROVE") | MaxMessageTermination(6)
    team = RoundRobinGroupChat([writer, editor], termination_condition=termination)

    await Console(team.run_stream(task="Write a 100-word post on vector databases."))
    await model.close()

asyncio.run(main())

# Research + write team with web tool, selector chat, and termination on approval.
import asyncio
from autogen_agentchat.agents import AssistantAgent, UserProxyAgent
from autogen_agentchat.teams import SelectorGroupChat
from autogen_agentchat.conditions import TextMentionTermination
from autogen_agentchat.ui import Console
from autogen_ext.models.openai import OpenAIChatCompletionClient

async def web_search(query: str) -> str:
    """Return summaries for the top N results."""
    return f"[stub] results for: {query}"

async def main() -> None:
    model = OpenAIChatCompletionClient(model="gpt-4o-mini")

    researcher = AssistantAgent(
        "researcher", model, tools=[web_search],
        system_message="Find 3 primary sources. Cite each.",
    )
    writer = AssistantAgent(
        "writer", model,
        system_message="Turn research into a 200-word post. End drafts with 'DRAFT_READY'.",
    )
    reviewer = AssistantAgent(
        "reviewer", model,
        system_message="Approve or revise. When happy, reply 'APPROVE'.",
    )

    team = SelectorGroupChat(
        participants=[researcher, writer, reviewer],
        model_client=model,
        termination_condition=TextMentionTermination("APPROVE"),
    )

    await Console(team.run_stream(task="Post on Postgres pgvector in 2026."))
    await model.close()

asyncio.run(main())