Class LocalAgentTaskState

src/tasks/local_agent.py:36–93

Runtime state for a background ``local_agent`` task. Field accounting (chapter-correct full set; refactoring plan WI-2.3 now lands what WI-1.5 stubbed): Stays from base: id, type, status, description, start_time, output_file (now the sidechain JSONL path), output_offset

@dataclass(kw_only=True)
class LocalAgentTaskState(TaskStateBase):
    """Runtime state for a background ``local_agent`` task.

    Field accounting (chapter-correct full set; refactoring plan WI-2.3
    now lands what WI-1.5 stubbed):

    Stays from base:
        id, type, status, description, start_time, output_file (now
        the sidechain JSONL path), output_offset, notified, tool_use_id,
        end_time, total_paused_seconds.

    Extension fields:
        agent_id            — same string as ``id``; kept as a separate
                              field for chapter-fidelity with TS.
        agent_type          — agent definition's ``agent_type``
                              (general-purpose, worker, fork, ...).
        prompt              — the user-supplied prompt text.
        selected_agent      — the resolved AgentDefinition; loose-typed
                              to avoid an import cycle.
        model               — optional per-spawn model override.
        abort_event         — asyncio.Event for cooperative kill.
        pending_messages    — Chunk D / WI-3.3 inbox; SendMessage
                              queues here for delivery at next tool
                              round.
        is_backgrounded     — was this spawned async or promoted later?
        retain              — UI is "holding" this task; blocks
                              eviction (Chunk D / WI-3.4).
        disk_loaded         — bootstrap has read the JSONL transcript
                              and merged it into ``messages``.
        evict_after         — Chunk D / WI-3.4 eviction grace deadline.
        progress            — live ``AgentProgress`` snapshot.
        last_reported_*     — delta-tracking for SDK progress events.
        result_text / error — final output container.
    """

    type: Literal["local_agent"] = "local_agent"  # type: ignore[assignment]
    agent_id: str = ""
    agent_type: str = ""
    prompt: str = ""
    selected_agent: Any = None  # AgentDefinition; loose to avoid cycles.
    model: str | None = None
    abort_event: asyncio.Event | None = field(default=None, repr=False, compare=False)
    pending_messages: list[str] = field(default_factory=list)
    is_backgrounded: bool = True
    retain: bool = False
    disk_loaded: bool = False
    evict_after: float | None = None
    progress: "AgentProgress | None" = None
    last_reported_tool_count: int = 0
    last_reported_token_count: int = 0
    result_text: str = ""
    error: str | None = None
    # Chunk F / WI-7.4 race guard. Set True by the auto-resume claim
    # mutator when this terminal state is being re-spawned; concurrent
    # SendMessage callers see the flag and back off to queueing the
    # message onto the resumed agent's pending_messages instead.
    # Reset to False on the fresh state ``register_async_agent`` upserts.
    is_resuming: bool = False