Struct ExecutionSnapshot 

#[non_exhaustive]
pub struct ExecutionSnapshot {

    pub execution_id: ExecutionId,
    pub flow_id: Option<FlowId>,
    pub lane_id: LaneId,
    pub namespace: Namespace,
    pub public_state: PublicState,
    pub blocking_reason: Option<String>,
    pub blocking_detail: Option<String>,
    pub current_attempt: Option<AttemptSummary>,
    pub current_lease: Option<LeaseSummary>,
    pub current_waitpoint: Option<WaitpointId>,
    pub created_at: TimestampMs,
    pub last_mutation_at: TimestampMs,
    pub total_attempt_count: u32,
    pub tags: BTreeMap<String, String>,
}

Engine-decoupled read-model for one execution.

Returned by ff_sdk::FlowFabricWorker::describe_execution. Consumers consult this struct instead of reaching into Valkey’s exec_core hash directly — the engine is free to rename fields or restructure storage under this surface.

#[non_exhaustive] — FF may add fields in minor releases without a semver break. Match with .. or use field-by-field construction.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

execution_id: ExecutionId

flow_id: Option<FlowId>

lane_id: LaneId

namespace: Namespace

public_state: PublicState

blocking_reason: Option<String>

Blocking reason string (e.g. "waiting_for_worker", "waiting_for_delay", "waiting_for_dependencies"). None when the exec_core field is empty.

blocking_detail: Option<String>

Free-form operator-readable detail explaining blocking_reason. None when the exec_core field is empty.

current_attempt: Option<AttemptSummary>

Summary of the execution’s currently-active attempt. None when no attempt has been started (pre-claim) or when the exec_core attempt fields are all empty.

current_lease: Option<LeaseSummary>

Summary of the execution’s currently-held lease. None when the execution is not held by a worker.

current_waitpoint: Option<WaitpointId>

The waitpoint this execution is currently suspended on, if any.

created_at: TimestampMs

last_mutation_at: TimestampMs

Timestamp of the last write that mutated exec_core. Engine-maintained.

total_attempt_count: u32

tags: BTreeMap<String, String>

Caller-owned labels. The prefix ^[a-z][a-z0-9_]*\. is reserved for consumer metadata (e.g. cairn.task_id); FF guarantees it will not write keys matching that shape. FF’s own fields stay in snake_case without dots. Empty when no tags are set.

Implementations

impl ExecutionSnapshot

pub fn new( execution_id: ExecutionId, flow_id: Option<FlowId>, lane_id: LaneId, namespace: Namespace, public_state: PublicState, blocking_reason: Option<String>, blocking_detail: Option<String>, current_attempt: Option<AttemptSummary>, current_lease: Option<LeaseSummary>, current_waitpoint: Option<WaitpointId>, created_at: TimestampMs, last_mutation_at: TimestampMs, total_attempt_count: u32, tags: BTreeMap<String, String>, ) -> Self

Construct an ExecutionSnapshot. Present so downstream crates (ff-sdk’s describe_execution) can assemble the struct despite the #[non_exhaustive] marker. Prefer adding builder-style helpers here over loosening non_exhaustive.

Trait Implementations

impl Clone for ExecutionSnapshot

fn clone(&self) -> ExecutionSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionSnapshot

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

Formats the value using the given formatter.

impl PartialEq for ExecutionSnapshot

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ExecutionSnapshot

impl StructuralPartialEq for ExecutionSnapshot