团队流水线

import asyncio
import os

from agentscope.agent import Agent
from agentscope.console import launch_console
from agentscope.credential import DashScopeCredential
from agentscope.model import DashScopeChatModel
from agentscope.pipeline import TeamMember, TeamPipeline
from agentscope.tool import Toolkit
from agentscope.workspace import LocalWorkspace


async def main() -> None:
    async with LocalWorkspace(workdir="./workspace") as workspace:
        model = DashScopeChatModel(
            credential=DashScopeCredential(
                api_key=os.getenv("DASHSCOPE_API_KEY"),
            ),
            model="qwen3.8-max",
        )

        # 队长：负责拆解任务、分派与汇总。它必须带有工具箱，
        # 流水线会往里注册分派工具 TeamAssign
        leader = Agent(
            name="Leader",
            system_prompt="You're a team leader named 'Leader'.",
            model=model,
            toolkit=Toolkit(),
        )

        # 成员：普通的智能体，名字即队长分派时引用它的方式
        researcher = Agent(
            name="Researcher",
            system_prompt="You're a researcher named 'Researcher'.",
            model=model,
            toolkit=Toolkit(tools=await workspace.list_tools()),
            offloader=workspace,
        )
        coder = Agent(
            name="Coder",
            system_prompt="You're a programmer named 'Coder'.",
            model=model,
            toolkit=Toolkit(tools=await workspace.list_tools()),
            offloader=workspace,
        )

        pipe = TeamPipeline(
            leader=leader,
            members=[
                # description 会写进分派工具的说明，队长据此决定分派给谁
                TeamMember(
                    agent=researcher,
                    description="Investigates a question and reports findings.",
                ),
                TeamMember(
                    agent=coder,
                    description="Writes and runs code in the workspace.",
                ),
            ],
        )

        # 流水线满足 PipelineProtocol，可以直接交给终端 UI
        await launch_console(agent=pipe)


asyncio.run(main())

# 某个成员中途出现 RequireUserConfirmEvent，事件流随即结束
async for event in pipe.reply_stream(user_msg):
    ...

# 把用户的答复递回去，流水线按 reply_id 交给挂起的那个成员
async for event in pipe.reply_stream(user_confirm_result_event):
    ...