Struct TaskFlow 

pub struct TaskFlow {
    pub id: Uuid,
    pub graph_id: Uuid,
    pub project_id: Uuid,
    pub base_revision: Option<String>,
    pub state: FlowState,
    pub task_executions: HashMap<Uuid, TaskExecution>,
    pub created_at: DateTime<Utc>,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
    pub updated_at: DateTime<Utc>,
}

A TaskFlow - runtime instance of a TaskGraph.

Fields

id: Uuid

Unique flow ID.

graph_id: Uuid

Associated TaskGraph ID.

project_id: Uuid

Associated project ID.

base_revision: Option<String>

state: FlowState

Current flow state.

task_executions: HashMap<Uuid, TaskExecution>

Task execution states.

created_at: DateTime<Utc>

Creation timestamp.

started_at: Option<DateTime<Utc>>

Start timestamp.

completed_at: Option<DateTime<Utc>>

Completion timestamp.

updated_at: DateTime<Utc>

Last update timestamp.

Implementations

impl TaskFlow

pub fn new(graph_id: Uuid, project_id: Uuid, task_ids: &[Uuid]) -> Self

Creates a new TaskFlow from a graph.

pub fn start(&mut self) -> Result<(), FlowError>

Starts the flow.

pub fn pause(&mut self) -> Result<(), FlowError>

Pauses the flow.

pub fn resume(&mut self) -> Result<(), FlowError>

Resumes the flow.

pub fn abort(&mut self) -> Result<(), FlowError>

Aborts the flow.

pub fn complete(&mut self) -> Result<(), FlowError>

Marks the flow as completed.

pub fn get_task_execution(&self, task_id: Uuid) -> Option<&TaskExecution>

Gets the execution state for a task.

pub fn get_task_execution_mut( &mut self, task_id: Uuid, ) -> Option<&mut TaskExecution>

Gets mutable execution state for a task.

pub fn transition_task( &mut self, task_id: Uuid, new_state: TaskExecState, ) -> Result<(), FlowError>

Transitions a task to a new state.

pub fn is_terminal(&self) -> bool

Checks if the flow is in a terminal state.

pub fn tasks_in_state(&self, state: TaskExecState) -> Vec<Uuid>

Gets tasks in a particular state.

pub fn task_state_counts(&self) -> HashMap<TaskExecState, usize>

Counts tasks by state.

Trait Implementations

impl Clone for TaskFlow

fn clone(&self) -> TaskFlow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskFlow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskFlow

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskFlow

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

where __S: Serializer,

Serialize this value into the given Serde serializer.