Struct WorkflowRunSnapshot 

pub struct WorkflowRunSnapshot {
    pub run_id: String,
    pub spec: WorkflowSpec,
    pub input: JsonValue,
    pub status: WorkflowRunStatus,
    pub steps: BTreeMap<String, StepSnapshot>,
    pub waits: BTreeMap<String, WaitSnapshot>,
    pub hooks: BTreeMap<String, HookSnapshot>,
    pub output: Option<JsonValue>,
    pub error: Option<String>,
    pub last_sequence: u64,
}

Materialized state of a workflow run.

Fields

run_id: String

spec: WorkflowSpec

input: JsonValue

status: WorkflowRunStatus

steps: BTreeMap<String, StepSnapshot>

waits: BTreeMap<String, WaitSnapshot>

hooks: BTreeMap<String, HookSnapshot>

output: Option<JsonValue>

error: Option<String>

last_sequence: u64

Implementations

impl WorkflowRunSnapshot

pub fn input_as<T>(&self) -> Result<T>

where T: DeserializeOwned,

Decode the workflow input into a host-defined serde type.

pub fn output_as<T>(&self) -> Result<Option<T>>

where T: DeserializeOwned,

Decode the terminal workflow output into a host-defined serde type.

pub fn step_output(&self, step_id: &str) -> Option<&JsonValue>

pub fn step_output_as<T>(&self, step_id: &str) -> Result<Option<T>>

where T: DeserializeOwned,

Decode a persisted step output into a host-defined serde type.

pub fn hook_payload(&self, hook_id: &str) -> Option<&JsonValue>

pub fn hook_metadata_as<T>(&self, hook_id: &str) -> Result<Option<T>>

where T: DeserializeOwned,

Decode persisted hook metadata into a host-defined serde type.

pub fn hook_payload_as<T>(&self, hook_id: &str) -> Result<Option<T>>

where T: DeserializeOwned,

Decode a received hook payload into a host-defined serde type.

pub fn has_open_suspension(&self) -> bool

pub fn due_retries(&self, now: DateTime<Utc>) -> Vec<(String, DateTime<Utc>)>

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

Trait Implementations

impl Clone for WorkflowRunSnapshot

fn clone(&self) -> WorkflowRunSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowRunSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowRunSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorkflowRunSnapshot

fn eq(&self, other: &WorkflowRunSnapshot) -> 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 Serialize for WorkflowRunSnapshot

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 WorkflowRunSnapshot