Struct DynamicWorkflowControlSnapshot 

pub struct DynamicWorkflowControlSnapshot {
    pub run_id: String,
    pub status: WorkflowRunStatus,
    pub last_sequence: u64,
    pub step_count: usize,
    pub completed_steps: usize,
    pub open_steps: usize,
    pub cancellation_requested: bool,
    pub continuation_identity: ExecutionIdentityV1,
    pub plan_identity: ExecutionIdentityV1,
    pub runtime_build_id: Option<String>,
    pub worker_lease: FlowDecisionClaimState,
}

Bounded, host-facing projection of one dynamic workflow continuation.

The projection deliberately omits source, input, step arguments, outputs, and worker owner tokens. Flow history remains available through the explicit inspection APIs when a trusted host needs the full record.

Fields

run_id: String

Stable durable run identifier.

status: WorkflowRunStatus

Current materialized Flow status.

last_sequence: u64

Last durable event sequence observed for the run.

step_count: usize

Number of durable step definitions in the run.

completed_steps: usize

Number of steps with a committed output.

open_steps: usize

Number of steps that remain actionable or in flight.

cancellation_requested: bool

Whether Flow has recorded a cleanup-aware cancellation request.

continuation_identity: ExecutionIdentityV1

Digest-only identity reconstructed from immutable continuation facts.

plan_identity: ExecutionIdentityV1

Digest-only identity of the projected immutable step plan.

runtime_build_id: Option<String>

Runtime build pinned by the durable run, or None for a legacy unpinned history.

worker_lease: FlowDecisionClaimState

Redacted worker-lease state observed by the control operation.

Trait Implementations

impl Clone for DynamicWorkflowControlSnapshot

fn clone(&self) -> DynamicWorkflowControlSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DynamicWorkflowControlSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DynamicWorkflowControlSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DynamicWorkflowControlSnapshot

impl PartialEq for DynamicWorkflowControlSnapshot

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for DynamicWorkflowControlSnapshot

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 DynamicWorkflowControlSnapshot