taolib.testing.multi_agent.agents.base#
智能体基类。
定义所有智能体必须实现的基础接口。
Classes#
智能体基类。 |
Module Contents#
- class taolib.testing.multi_agent.agents.base.BaseAgent(document: taolib.testing.multi_agent.models.AgentDocument)#
Bases:
abc.ABC智能体基类。
- _document#
- _status#
- _current_task: taolib.testing.multi_agent.models.TaskDocument | None = None#
- _message_queue: list[taolib.testing.multi_agent.models.Message] = []#
- property status: taolib.testing.multi_agent.models.AgentStatus#
获取智能体状态。
- property document: taolib.testing.multi_agent.models.AgentDocument#
获取智能体文档。
- property current_task: taolib.testing.multi_agent.models.TaskDocument | None#
获取当前任务。
- async send_message(message: taolib.testing.multi_agent.models.Message) None#
发送消息。
- 参数:
message -- 要发送的消息
- async receive_message(message: taolib.testing.multi_agent.models.Message) None#
接收消息。
- 参数:
message -- 接收到的消息
- async _on_message_sent(message: taolib.testing.multi_agent.models.Message) None#
消息发送后的回调。
- 参数:
message -- 发送的消息
- abstractmethod _handle_message(message: taolib.testing.multi_agent.models.Message) None#
- Async:
处理接收到的消息。
- 参数:
message -- 接收到的消息
- abstractmethod execute_task(task: taolib.testing.multi_agent.models.TaskDocument) None#
- Async:
执行任务。
- 参数:
task -- 要执行的任务
- async assign_task(task: taolib.testing.multi_agent.models.TaskDocument) None#
分配任务给智能体。
- 参数:
task -- 要分配的任务
- 抛出:
AgentError -- 智能体忙碌
- async _on_task_assigned(task: taolib.testing.multi_agent.models.TaskDocument) None#
任务分配后的回调。
- 参数:
task -- 分配的任务
- async complete_task(success: bool, result: Any | None = None) None#
完成当前任务。
- 参数:
success -- 是否成功
result -- 任务结果
- async _on_task_completed(task: taolib.testing.multi_agent.models.TaskDocument, success: bool, result: Any | None) None#
任务完成后的回调。
- 参数:
task -- 完成的任务
success -- 是否成功
result -- 任务结果