给 Worker 分配任务。 关键:任务描述必须是自包含的! 不能说"根据之前的讨论去做",因为 Worker 不知道之前讨论了什么。 对应 Reference: EP03 §2 "协调者必须编写自包含的 Prompt, 包括 Worker 所需的一切:文件路径、行号、错误信息 以及'完成'的标准。"
(self, worker_name: str, task: str)
| 365 | return worker |
| 366 | |
| 367 | def assign_task(self, worker_name: str, task: str): |
| 368 | """ |
| 369 | 给 Worker 分配任务。 |
| 370 | |
| 371 | 关键:任务描述必须是自包含的! |
| 372 | 不能说"根据之前的讨论去做",因为 Worker 不知道之前讨论了什么。 |
| 373 | |
| 374 | 对应 Reference: EP03 §2 |
| 375 | "协调者必须编写自包含的 Prompt, |
| 376 | 包括 Worker 所需的一切:文件路径、行号、错误信息 |
| 377 | 以及'完成'的标准。" |
| 378 | """ |
| 379 | self.mailbox.send(AgentMessage( |
| 380 | from_agent=self.identity.name, |
| 381 | to_agent=worker_name, |
| 382 | msg_type=MessageType.TASK, |
| 383 | content=task, |
| 384 | )) |
| 385 | print(f" [Leader] 分配任务给 {worker_name}: {task[:40]}...") |
| 386 | |
| 387 | def collect_results(self) -> list[AgentMessage]: |
| 388 | """收集 Worker 的结果""" |
no test coverage detected