Struct Execution 

pub struct Execution {

    pub domain: String,
    pub workflow_id: String,
    pub run_id: String,
    pub workflow_type_name: String,
    pub workflow_type_version: String,
    pub task_list: String,
    pub task_priority: Option<String>,
    pub status: String,
    pub close_status: Option<String>,
    pub start_timestamp: f64,
    pub close_timestamp: Option<f64>,
    pub tag_list: Vec<String>,
    pub input: Option<String>,
    pub child_policy: String,
    pub task_start_to_close_timeout: String,
    pub execution_start_to_close_timeout: String,
    pub lambda_role: Option<String>,
    pub cancel_requested: bool,
    pub latest_execution_context: Option<String>,
    pub events: Vec<Value>,
    pub next_event_id: i64,
    pub decision_scheduled: bool,
    pub decision_scheduled_event_id: Option<i64>,
    pub decision_started_event_id: Option<i64>,
    pub previous_started_event_id: i64,
    pub decision_task_token: Option<String>,
    pub activities: Vec<ActivityRecord>,
}

A workflow execution and everything the state machine needs to drive it.

Fields

domain: String

workflow_id: String

run_id: String

workflow_type_name: String

workflow_type_version: String

task_list: String

task_priority: Option<String>

status: String

OPEN or CLOSED.

close_status: Option<String>

COMPLETED / FAILED / CANCELED / TERMINATED / TIMED_OUT / CONTINUED_AS_NEW once closed.

start_timestamp: f64

close_timestamp: Option<f64>

tag_list: Vec<String>

input: Option<String>

child_policy: String

task_start_to_close_timeout: String

execution_start_to_close_timeout: String

lambda_role: Option<String>

cancel_requested: bool

latest_execution_context: Option<String>

events: Vec<Value>

The ordered event history, each entry an already-output-valid HistoryEvent wire object.

next_event_id: i64

The next eventId to assign (1-based, monotonic).

decision_scheduled: bool

A decision task is scheduled and awaiting a poll.

decision_scheduled_event_id: Option<i64>

The eventId of the outstanding DecisionTaskScheduled event.

decision_started_event_id: Option<i64>

The eventId of the DecisionTaskStarted for an in-flight decision.

previous_started_event_id: i64

The eventId of the previous DecisionTaskStarted (for the next poll).

decision_task_token: Option<String>

The task token handed out for the in-flight decision task, if any.

activities: Vec<ActivityRecord>

Activity tasks tracked by this execution, in schedule order.

Implementations

impl Execution

pub fn alloc_event_id(&mut self) -> i64

Allocate the next monotonic event id.

Trait Implementations

impl Clone for Execution

fn clone(&self) -> Execution

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Execution

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Execution

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Execution

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

where __S: Serializer,

Serialize this value into the given Serde serializer.