9. צוותי סוכנים

הבעיה

תת-סוכנים הם חד-פעמיים: נולדים, עובדים, מחזירים סיכום, מתים. אין זהות, אין זיכרון בין הפעלות. משימות רקע מריצות פקודות shell אבל לא יכולות לקבל החלטות מודרכות על ידי LLM.

עבודת צוות אמיתית צריכה: (1) סוכנים מתמשכים שחיים מעבר לפרומפט יחיד, (2) ניהול זהות ומחזור חיים, (3) ערוץ תקשורת בין סוכנים.

הפתרון

Teammate lifecycle:
  spawn -> WORKING -> IDLE -> WORKING -> ... -> SHUTDOWN

Communication:
  .team/
    config.json           <- team roster + statuses
    inbox/
      alice.jsonl         <- append-only, drain-on-read
      bob.jsonl
      lead.jsonl

          +--------+    send("alice","bob","...")    +--------+
          | lead   | -----------------------------> |  bob   |
          +--------+                                +--------+
               ^                                        |
               |           inbox/lead.jsonl             |
               +----------------------------------------+

איך זה עובד

1. תצורת הצוות שומרת roster וסטטוסים.

import json, threading
from pathlib import Path

TEAM_DIR = Path(".team")
INBOX_DIR = TEAM_DIR / "inbox"
TEAM_DIR.mkdir(exist_ok=True)
INBOX_DIR.mkdir(exist_ok=True)

def init_team(teammates: list) -> None:
    config = {
        "teammates": [
            {"name": t["name"], "role": t["role"], "status": "IDLE"}
            for t in teammates
        ]
    }
    (TEAM_DIR / "config.json").write_text(json.dumps(config, indent=2))
    for t in teammates:
        (INBOX_DIR / f"{t['name']}.jsonl").touch()

def get_roster() -> list:
    config = json.loads((TEAM_DIR / "config.json").read_text())
    return config["teammates"]

2. תיבות הדואר הן קבצי JSONL append-only. ריקון פירושו קריאה-וחיתוך.

def send_message(to: str, from_: str, content: str) -> str:
    inbox = INBOX_DIR / f"{to}.jsonl"
    msg = {"from": from_, "content": content}
    with open(inbox, "a") as f:
        f.write(json.dumps(msg) + "\n")
    return f"Message sent to {to}."

def drain_inbox(name: str) -> list:
    inbox = INBOX_DIR / f"{name}.jsonl"
    if not inbox.exists() or inbox.stat().st_size == 0:
        return []
    lines = inbox.read_text().strip().split("\n")
    inbox.write_text("")  # truncate after reading
    return [json.loads(l) for l in lines if l]

3. כל חבר צוות מריץ לולאת סוכן משלו ב-thread.

def teammate_loop(name: str, role: str) -> None:
    system = f"You are {name}, a {role}. Check your inbox for tasks."
    while True:
        inbox_messages = drain_inbox(name)
        if not inbox_messages:
            # IDLE: wait for work
            threading.Event().wait(timeout=2)
            continue

        update_status(name, "WORKING")
        history = [{"role": "user", "content":
            "\n".join(m["content"] for m in inbox_messages)}]
        # run agent loop with history
        result = run_agent(history, system)
        send_message("lead", name, result)
        update_status(name, "IDLE")

מה השתנה מ-משימות רקע

מסקנה מרכזית

תבנית תיבת הדואר היא מה שגורם לצוותי סוכנים לעבוד. לכל חבר צוות יש תיבת דואר פרטית על הדיסק — עמידה, בטוחה לגישה מקבילית, ושקופה. המוביל מאציל על ידי שליחת הודעה; חבר הצוות מרוקן את תיבת הדואר שלו ומגיב. אין זיכרון משותף, אין צורך במנעולים — רק קבצים.