Struct TaskExecution 

pub struct TaskExecution {
    pub task_id: Uuid,
    pub state: TaskExecState,
    pub attempt_count: u32,
    pub retry_mode: RetryMode,
    pub frozen_commit_sha: Option<String>,
    pub integrated_commit_sha: Option<String>,
    pub updated_at: DateTime<Utc>,
    pub blocked_reason: Option<String>,
}

Execution state for a single task within a flow.

Fields

task_id: Uuid

Task ID (from TaskGraph).

state: TaskExecState

Current execution state.

attempt_count: u32

Number of attempts made.

retry_mode: RetryMode

frozen_commit_sha: Option<String>

integrated_commit_sha: Option<String>

updated_at: DateTime<Utc>

Last state change timestamp.

blocked_reason: Option<String>

Blocking reason (if blocked).

Implementations

impl TaskExecution

pub fn new(task_id: Uuid) -> Self

Creates a new task execution in Pending state.

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

Transitions to a new state.

pub fn can_transition_to(&self, new_state: TaskExecState) -> bool

Checks if a transition is valid.

Trait Implementations

impl Clone for TaskExecution

fn clone(&self) -> TaskExecution

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskExecution

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskExecution

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskExecution

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

where __S: Serializer,

Serialize this value into the given Serde serializer.