Struct WorkItem 

pub struct WorkItem {

    pub id: String,
    pub run_id: RunId,
    pub tenant_id: TenantId,
    pub subject_id: SubjectId,
    pub spec_id: String,
    pub definition_id: String,
    pub workflow_revision: u64,
    pub workflow_revision_digest: String,
    pub execution_profile_id: String,
    pub execution_profile_revision: u64,
    pub execution_profile_digest: String,
    pub kernel_abi_version: String,
    pub capability_pins: Vec<CapabilityPin>,
    pub lifecycle: LifecyclePolicy,
    pub scheduled_at: DateTime<Utc>,
    pub claimed_at: DateTime<Utc>,
    pub config: Value,
    pub state_version: i64,
    pub control_epochs: ControlEpochs,
    pub cancel_requested: bool,
    pub lease_version: i64,
    pub wakeups: Vec<Wakeup>,
}

One claimed instance with everything a driver needs to evaluate it.

Fields

id: String

Stable identifier of this record.

run_id: RunId

Run this record belongs to.

tenant_id: TenantId

Tenant that owns this record.

subject_id: SubjectId

Subject (user or service principal) acting on or owning this record.

spec_id: String

Workflow spec identifier.

definition_id: String

Workflow definition this record belongs to.

workflow_revision: u64

Pinned workflow revision.

workflow_revision_digest: String

Digest of the pinned revision.

execution_profile_id: String

Pinned execution profile.

execution_profile_revision: u64

Pinned execution profile revision.

execution_profile_digest: String

Digest of the pinned profile.

kernel_abi_version: String

Kernel ABI the revision pinned.

capability_pins: Vec<CapabilityPin>

Capabilities the revision may dispatch.

lifecycle: LifecyclePolicy

Completion, timeout and catch-up policy pinned by the revision.

scheduled_at: DateTime<Utc>

Database timestamps captured by the claim transaction. Scheduling logic never consults an application-host clock.

claimed_at: DateTime<Utc>

Database time of the claim.

config: Value

Configuration object validated against the declared schema.

state_version: i64

CAS version the command must be committed against.

control_epochs: ControlEpochs

Control epochs at claim time.

cancel_requested: bool

Whether cancellation was requested; the terminal commit honours it.

lease_version: i64

Fencing token bumped on every lease acquisition; stale holders cannot write.

wakeups: Vec<Wakeup>

Due timers and trigger deliveries, oldest first.

Trait Implementations

impl Clone for WorkItem

fn clone(&self) -> WorkItem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkItem

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

Formats the value using the given formatter.

impl PartialEq for WorkItem

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkItem