Struct SubagentState 

pub struct SubagentState {

    pub status: SubagentStatus,
    pub partial_text: String,
    pub tool_log: Vec<String>,
    pub conversation_state: Vec<Value>,
    pub finished_at: Option<Instant>,
    pub cancel_requested: bool,
    pub stopped_by_reload: bool,
    pub completion_settled: bool,
    pub terminal: Option<TerminalDiagnostic>,
    pub step: String,
    pub tools: u32,
    pub history: Option<Vec<SharedMessage>>,
    pub last_response_start: usize,
    pub archive_meta: Option<SubagentArchiveMeta>,
    pub archive_dir: Option<PathBuf>,
    pub archive_path: Option<PathBuf>,
    pub cache_anchor_unix_ms: Option<u64>,
    pub context_window: u64,
    pub context_rollovers: u32,
    pub context_transcripts: Vec<PathBuf>,
    pub finalization_started: bool,
    pub finalization_ready: bool,
    pub archive_error: Option<String>,
    pub watch: WatchJournal,
}

All mutable state shared between the subagent thread and its handle. Collapsed behind a single RwLock so a status poll takes exactly one lock.

Fields

status: SubagentStatus

partial_text: String

tool_log: Vec<String>

conversation_state: Vec<Value>

finished_at: Option<Instant>

Stamped once by finalize_subagent at thread exit.

cancel_requested: bool

Set by cancel() before the shutdown signal is sent. Read by finalize_subagent to label the terminal status correctly.

stopped_by_reload: bool

Stopped by a daemon reload (SubagentRegistry::stop_for_reload), not by the user: the run is resumable from its archive.

completion_settled: bool

The finalizer ran to its end: the archive is written and the completion wake pushed (or deliberately withheld, e.g. a cancel). A reload waits for this so the wake is in the queue it carries.

terminal: Option<TerminalDiagnostic>

step: String

What the worker is doing right now: the same text as its latest SubagentUpdate (“💭 thinking…”, “⚙ bash (tool #2)”, “$ cargo test”). Those events ride the stream of the turn that started the worker; a background worker outlives that turn, so clients read its progress from here (via SubagentDisplayRow) once the turn has ended.

tools: u32

Tool calls started so far (the “tool #N” in step).

history: Option<Vec<SharedMessage>>

The worker’s real message history, from the runtime’s last SessionEvent::MessageHistory. Written to the resume archive by the finalizer and then released, so finished handles stay small.

last_response_start: usize

Byte offset in partial_text where the latest model response starts. Completion previews show that response (the worker’s final word), not the first words of the whole run.

archive_meta: Option<SubagentArchiveMeta>

Identity needed to resume from the archive after the handle is reaped.

archive_dir: Option<PathBuf>

Archive destination captured at launch, independent of later config changes.

archive_path: Option<PathBuf>

Where the finalizer wrote this worker’s resume archive.

cache_anchor_unix_ms: Option<u64>

Wall-clock start (Unix ms) of the run’s last accepted Anthropic request, captured when the run ends. subagent_resume compares it to the worker cache TTL: an expired prefix would be rewritten in full, so a large cold history is resumed from a compact context instead.

context_window: u64

The worker’s current context window (1 until its context first rolls over; a resumed rolled worker starts at its archived window).

context_rollovers: u32

Automatic context rollovers in this run.

context_transcripts: Vec<PathBuf>

Transcripts of every earlier context window, oldest first.

finalization_started: bool

Managed workers remain publicly running until their recovery outcome is published.

finalization_ready: bool

archive_error: Option<String>

watch: WatchJournal

What the worker has shown so far, for clients watching it in its own thread view (SessionQuery::SubagentWatch). Bounded.

Implementations

impl SubagentState

pub fn public_status(&self) -> SubagentStatus

pub fn new() -> Self

pub fn note_progress(&mut self, step: &str, tools: u32)

Record the worker’s latest progress line and tool count.

pub fn note_context(&mut self, window: u64, transcripts: Vec<PathBuf>)

Record where the worker’s context stands: at launch from a resumed history, then after each rollover.

pub fn context_summary(&self) -> Option<Value>

{"window", "rollovers", "transcripts"} for status/collect once the worker’s context has rolled over; None before (outputs unchanged).

pub fn last_response_text(&self) -> &str

Text of the latest model response (empty if none started yet).

pub fn safe_fail(&mut self, diagnostic: TerminalDiagnostic)

Persist only typed, allowlisted failure data. Raw provider errors never enter state.

Trait Implementations

impl Debug for SubagentState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SubagentState

fn default() -> Self

Returns the “default value” for a type.