(teammate: str)
| 619 | # ── Lead Protocol Tools (s16 new) ── |
| 620 | |
| 621 | def run_request_shutdown(teammate: str) -> str: |
| 622 | req_id = new_request_id() |
| 623 | pending_requests[req_id] = ProtocolState( |
| 624 | request_id=req_id, type="shutdown", |
| 625 | sender="lead", target=teammate, |
| 626 | status="pending", payload="") |
| 627 | BUS.send("lead", teammate, "Please shut down gracefully.", |
| 628 | "shutdown_request", |
| 629 | {"request_id": req_id}) |
| 630 | print(f" \033[35m[protocol] shutdown_request → {teammate} " |
| 631 | f"({req_id})\033[0m") |
| 632 | return f"Shutdown request sent to {teammate} (req: {req_id})" |
| 633 | |
| 634 | |
| 635 | def run_request_plan(teammate: str, task: str) -> str: |
nothing calls this directly
no test coverage detected