autogen_agentchat.base._team 源代码

from abc import ABC, abstractmethod
from typing import Any, Mapping

from autogen_core import ComponentBase
from pydantic import BaseModel

from ._task import TaskRunner




class Team(ABC, TaskRunner, ComponentBase[BaseModel]):
    component_type = "team"



    @abstractmethod
    async def reset(self) -> None:
        """重置团队及其所有参与者至初始状态。"""
        ...




    @abstractmethod
    async def pause(self) -> None:
        """暂停团队及其所有参与者。这在需要暂停 :meth:`autogen_agentchat.base.TaskRunner.run` 或
        :meth:`autogen_agentchat.base.TaskRunner.run_stream` 方法的并发执行时非常有用，
        同时保持它们的运行状态。"""
        ...




    @abstractmethod
    async def resume(self) -> None:
        """在调用 :meth:`pause` 后，恢复团队及其所有参与者从暂停状态继续运行。"""
        ...




    @abstractmethod
    async def save_state(self) -> Mapping[str, Any]:
        """保存团队的当前状态。"""
        ...




    @abstractmethod
    async def load_state(self, state: Mapping[str, Any]) -> None:
        """加载团队的状态。"""
        ...