MCPcopy Create free account
hub / github.com/Louisym/MiniCC / assign_task

Method assign_task

tutorials/13_multi_agent_coordination.py:367–385  ·  view source on GitHub ↗

给 Worker 分配任务。 关键:任务描述必须是自包含的! 不能说"根据之前的讨论去做",因为 Worker 不知道之前讨论了什么。 对应 Reference: EP03 §2 "协调者必须编写自包含的 Prompt, 包括 Worker 所需的一切:文件路径、行号、错误信息 以及'完成'的标准。"

(self, worker_name: str, task: str)

Source from the content-addressed store, hash-verified

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 的结果"""

Callers 1

demo_four_phase_workflowFunction · 0.95

Calls 2

AgentMessageClass · 0.85
sendMethod · 0.80

Tested by

no test coverage detected