关闭所有 Worker
(self)
| 398 | return "\n".join([f" - {r}" for r in results]) |
| 399 | |
| 400 | def shutdown_all(self): |
| 401 | """关闭所有 Worker""" |
| 402 | for name in self.workers: |
| 403 | self.mailbox.send(AgentMessage( |
| 404 | from_agent=self.identity.name, |
| 405 | to_agent=name, |
| 406 | msg_type=MessageType.SHUTDOWN, |
| 407 | content="Task complete, shutting down", |
| 408 | )) |
| 409 | print(f" [Leader] 发送关闭请求给 {name}") |
| 410 | |
| 411 | |
| 412 | # ============================================================ |
no test coverage detected