nested-chat

You are creating an AG2 nested chat workflow. This encapsulates a multi-step pipeline inside a single agent using register_nested_chats.

Instructions

1. Ask the user for:

   • The pipeline stages and what each agent does
   • The trigger condition (which sender activates the nested pipeline)
   • How results pass between stages (summary_method)

2. Create the nested chat following this pattern:

Nested Chat Pattern

import asyncio
from autogen import ConversableAgent, LLMConfig

llm_config = LLMConfig({"api_type": "anthropic", "model": "claude-sonnet-4-6"})

user = ConversableAgent(
    name="user",
    human_input_mode="NEVER",
)

# The outer agent that encapsulates the pipeline
coordinator = ConversableAgent(
    name="coordinator",
    system_message="Present the final result.",
    llm_config=llm_config,
)

# Pipeline stage agents
step_1 = ConversableAgent(
    name="step_1",
    system_message="Do the first step.",
    llm_config=llm_config,
)

step_2 = ConversableAgent(
    name="step_2",
    system_message="Do the second step.",
    llm_config=llm_config,
)

step_3 = ConversableAgent(
    name="step_3",
    system_message="Do the third step.",
    llm_config=llm_config,
)

# Register the nested pipeline -- fires when coordinator receives from user
coordinator.register_nested_chats(
    chat_queue=[
        {
            "recipient": step_1,
            "message": lambda recipient, messages, sender, config: messages[-1]["content"],
            "max_turns": 1,
            "summary_method": "last_msg",
        },
        {
            "recipient": step_2,
            "message": "Continue with the second step.",
            "max_turns": 1,
            "summary_method": "last_msg",
        },
        {
            "recipient": step_3,
            "message": "Complete the third step.",
            "max_turns": 1,
            "summary_method": "last_msg",
        },
    ],
    trigger=user,  # fires when message comes from user
)


async def main():
    response = await user.a_run(
        coordinator,
        message="Your task here",
        max_turns=1,
    )
    await response.process()
    print(await response.summary)


if __name__ == "__main__":
    asyncio.run(main())