Struct BackgroundSubagentRecord 

pub struct BackgroundSubagentRecord {

    pub schema_version: u32,
    pub attempt_id: SubagentAttemptId,
    pub agent_id: String,
    pub linked_task_id: Option<TaskId>,
    pub subagent_name: String,
    pub namespace_id: String,
    pub parent_session_id: SessionId,
    pub parent_run_id: RunId,
    pub child_run_id: Option<RunId>,
    pub continuation_run_id: Option<RunId>,
    pub profile: String,
    pub owner_lease: DurableBackgroundSubagentOwnerLease,
    pub execution_status: DurableBackgroundSubagentExecutionStatus,
    pub result_ref: Option<DurableBackgroundSubagentResultRef>,
    pub failure_category: Option<String>,
    pub cancellation_reason: Option<String>,
    pub delivery_status: DurableBackgroundSubagentDeliveryStatus,
    pub delivery_claim: Option<DurableBackgroundSubagentDeliveryClaim>,
    pub delivered_claim_id: Option<String>,
    pub automatic_continuation_suppressed_by_run_id: Option<RunId>,
    pub retention_status: DurableBackgroundSubagentRetentionStatus,
    pub retention_expires_at: Option<DateTime<Utc>>,
    pub trace_context: Option<TraceContext>,
    pub accepted_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
    pub terminal_at: Option<DateTime<Utc>>,
}

Durable service-host projection of one background attempt.

Fields

schema_version: u32

Version of this serialized record contract.

attempt_id: SubagentAttemptId

Per-execution attempt identity.

agent_id: String

Stable child conversation identity within the owning supervisor scope.

linked_task_id: Option<TaskId>

Optional independently owned task-bundle identity.

subagent_name: String

Configured subagent name.

namespace_id: String

Durable host namespace.

parent_session_id: SessionId

Owning parent session.

parent_run_id: RunId

Parent run that accepted delegation.

child_run_id: Option<RunId>

Child runtime run once known.

continuation_run_id: Option<RunId>

Parent continuation that consumed the result, when any.

profile: String

Resolved parent profile used for an automatic continuation.

owner_lease: DurableBackgroundSubagentOwnerLease

Fenced process owner for all non-terminal execution writes.

execution_status: DurableBackgroundSubagentExecutionStatus

Current monotonic execution state.

result_ref: Option<DurableBackgroundSubagentResultRef>

Terminal result reference, separate from minimal lifecycle evidence.

failure_category: Option<String>

Safe failure/interruption category.

cancellation_reason: Option<String>

Bounded cancellation reason.

delivery_status: DurableBackgroundSubagentDeliveryStatus

Logical result-delivery state.

delivery_claim: Option<DurableBackgroundSubagentDeliveryClaim>

Current bounded claim, when delivery is claimed.

delivered_claim_id: Option<String>

Claim that completed logical delivery.

automatic_continuation_suppressed_by_run_id: Option<RunId>

Failed or cancelled consumer that suppresses automatic continuation redelivery.

Explicit later parent runs may still claim and consume the pending result.

retention_status: DurableBackgroundSubagentRetentionStatus

Independent content-retention state.

retention_expires_at: Option<DateTime<Utc>>

Policy deadline for retained inline or artifact content.

trace_context: Option<TraceContext>

Parent trace correlation copied at acceptance.

accepted_at: DateTime<Utc>

Acceptance time.

updated_at: DateTime<Utc>

Last durable transition time.

terminal_at: Option<DateTime<Utc>>

Immutable terminal transition time.

Implementations

impl BackgroundSubagentRecord

pub fn is_valid_acceptance(&self) -> bool

Return whether this record is a canonical acceptance projection.

pub fn is_valid_terminal(&self) -> bool

Return whether this record is a canonical immutable terminal projection.

pub fn delivery_claimable_at(&self, now: DateTime<Utc>) -> bool

Return whether a claim may be acquired at now.

pub fn continuation_outcome(&self, artifact_content: Option<&str>) -> String

Resolve the canonical model-visible outcome for a continuation.

pub fn continuation_text(&self, artifact_content: Option<&str>) -> String

Build the canonical model-visible continuation text.

pub fn continuation_input( &self, artifact_content: Option<&str>, ) -> Vec<InputPart>

Build the exact durable input accepted for a result-triggered continuation.

pub fn validates_continuation_run(&self, run: &RunRecord) -> bool

Validate immutable causal fields on a proposed result-triggered continuation.

pub fn validates_continuation_cause_envelope( &self, cause: &BackgroundSubagentContinuationCause, run: &RunRecord, ) -> bool

Validate the typed causal envelope and its submitted input digest.

pub fn validates_continuation_cause( &self, cause: &BackgroundSubagentContinuationCause, run: &RunRecord, artifact_content: Option<&str>, ) -> bool

Validate a typed cause and exact canonical input against this durable result.

Trait Implementations

impl Clone for BackgroundSubagentRecord

fn clone(&self) -> BackgroundSubagentRecord

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BackgroundSubagentRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BackgroundSubagentRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BackgroundSubagentRecord

impl PartialEq for BackgroundSubagentRecord

fn eq(&self, other: &BackgroundSubagentRecord) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for BackgroundSubagentRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BackgroundSubagentRecord

impl VersionedRecord for BackgroundSubagentRecord

const SCHEMA: &'static str = "starweaver.session.background_subagent_record"

Stable schema identifier.

const VERSION: u32 = BACKGROUND_SUBAGENT_RECORD_VERSION

Current schema version.

const ALLOW_BARE_V0: bool = false

Whether this record explicitly accepts a previous bare-JSON v0 shape.

fn decode_version( version: u32, payload: Value, ) -> Result<Self, VersionedRecordError>

where Self: DeserializeOwned,

Decode one enveloped payload version.

fn decode_bare_v0(payload: Value) -> Result<Self, VersionedRecordError>

where Self: DeserializeOwned,

Decode the explicitly supported bare-JSON v0 shape.