feat(delegate-job): support --role parameter in submit and update commands to resolve role suitability mismatches

.agents/skills/multi-agent-mux-delegate-job/scripts/registry.py

@@ -51,6 +51,7 @@ def register_job(
     prompt: str,
     agent: str = "claude-code",
     agent_session: str = "tmux:claude",
+    role: str = "Worker",
     broker: Optional[Dict[str, Any]] = None,
     timeout_sec: int = 3600,
     idle_timeout_sec: int = 120,
@@ -87,6 +88,7 @@ def register_job(
         "prompt": prompt,
         "agent": agent,
         "agent_session": agent_session,
+        "role": role,
         "broker": broker,
         "topic_prefix": topic_prefix_for(job_id),
         "timeout_sec": int(timeout_sec),
@@ -239,6 +241,7 @@ def _build_parser() -> argparse.ArgumentParser:
     p_reg.add_argument("--prompt", required=True)
     p_reg.add_argument("--agent", default="claude-code")
     p_reg.add_argument("--agent-session", default="tmux:claude")
+    p_reg.add_argument("--role", default="Worker", help="logical role for the delegated agent (e.g. Worker, Planner, Reviewer)")
     p_reg.add_argument("--timeout", type=int, default=3600)
     p_reg.add_argument("--idle-timeout", type=int, default=120)
     p_reg.add_argument("--bits", type=int, default=32, help="32 (PoC) or 128 (prod)")
@@ -266,6 +269,7 @@ def _build_parser() -> argparse.ArgumentParser:
     p_update.add_argument("--agent-session", default=None)
     p_update.add_argument("--prompt", default=None)
     p_update.add_argument("--iteration", type=int, default=None)
+    p_update.add_argument("--role", default=None)
 
     p_feedback = sub.add_parser("get-feedback", help="get the last feedback detail (completed/error) for a job")
     p_feedback.add_argument("--job", required=True)
@@ -302,6 +306,7 @@ def main(argv: Optional[List[str]] = None) -> int:
             prompt=args.prompt,
             agent=args.agent,
             agent_session=args.agent_session,
+            role=args.role,
             timeout_sec=args.timeout,
             idle_timeout_sec=args.idle_timeout,
             registry_dir=rd,
@@ -354,6 +359,8 @@ def main(argv: Optional[List[str]] = None) -> int:
             fields["prompt"] = args.prompt
         if args.iteration is not None:
             fields["iteration"] = args.iteration
+        if args.role is not None:
+            fields["role"] = args.role
         try:
             mqtt_common.update_job_status(args.job, rd, **fields)
         except FileNotFoundError as exc: