Enum TaskState 

pub enum TaskState {
    Created,
    Queued,
    Running {
        worker_id: usize,
    },
    Suspended {
        waiting_on: Vec<TaskId>,
    },
    Completed {
        result: RtObject,
    },
    Failed {
        error: String,
    },
    Cancelled,
}

The state of a task in its lifecycle.

Variants

Created

Task has been created but not yet scheduled.

Queued

Task is in a queue waiting to be executed.

Running

Task is currently running on a worker.

Fields

worker_id: usize

Which worker is executing this task.

Suspended

Task is suspended (waiting for a dependency).

Fields

waiting_on: Vec<TaskId>

Task IDs this task is waiting on.

Completed

Task has completed successfully.

Fields

result: RtObject

The result value.

Failed

Task has failed with an error.

Fields

error: String

The error message.

Cancelled

Task has been cancelled.

Implementations

impl TaskState

pub fn is_terminal(&self) -> bool

Check if the task is in a terminal state.

pub fn is_runnable(&self) -> bool

Check if the task is runnable.

pub fn is_running(&self) -> bool

Check if the task is running.

pub fn is_suspended(&self) -> bool

Check if the task is suspended.

Trait Implementations

impl Clone for TaskState

fn clone(&self) -> TaskState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskState

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

Formats the value using the given formatter.

impl Display for TaskState

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

Formats the value using the given formatter.

impl PartialEq for TaskState

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

impl StructuralPartialEq for TaskState