Struct FlowRecord 

pub struct FlowRecord {
    pub id: i32,
    pub flow_name: String,
    pub status: FlowStatus,
    pub plan: Value,
    pub current_stage: i32,
    pub running_tasks: Vec<i32>,
    pub finished_tasks: Vec<i32>,
    pub failed_tasks: Vec<i32>,
    pub task_definitions: Value,
}

Detailed status of a flow.

Fields

id: i32

Unique identifier for the flow.

flow_name: String

Name of the flow as specified in crate::model::Flow.

status: FlowStatus

Status of the flow.

plan: Value

Execution plan of the flow. This is a nested 2D JSON array containing integer elements. The integer elements refer to index of a task defined in crate::model::Flow. A task is executed in multiple stages, where each stage is a set of tasks. The set of tasks in the last stage are dependent set of tasks in the last but second stage and so on, with the first stage having tasks that are independent having no dependencies (leaf tasks). Tasks belonging to the same stage are not dependent on each other, if a task is dependent on another task, they will belong to different stages.

current_stage: i32

Current stage that is running. Set of tasks in the same stage are spawned at the same time because they are not dependent on each other.

running_tasks: Vec<i32>

Indices of tasks that are currently running.

finished_tasks: Vec<i32>

Indices of tasks that have finished.

failed_tasks: Vec<i32>

Indices of tasks that have failed.

task_definitions: Value

List of tasks that belong to this flow, as define in crate::model::Flow.

Trait Implementations

impl Clone for FlowRecord

fn clone(&self) -> FlowRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FlowRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for FlowRecord

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

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for FlowRecord

where &'a str: ColumnIndex<R>, i32: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, FlowStatus: Decode<'a, R::Database> + Type<R::Database>, Value: Decode<'a, R::Database> + Type<R::Database>, Vec<i32>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>

impl PartialEq for FlowRecord

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

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 FlowRecord