Struct Task 

pub struct Task {
    pub name: &'static str,
    pub body: TaskBody,
    pub retries: u32,
    pub timeout: Option<Duration>,
    pub status: TaskStatus,
    pub remaining_deps: AtomicUsize,
    pub initial_deps: usize,
    pub current_retry: AtomicU32,
}

A task in the DAG.

Fields

name: &'static str

Human-readable name of the task.

body: TaskBody

The executable logic.

retries: u32

Number of retries allowed.

timeout: Option<Duration>

Timeout duration.

status: TaskStatus

Current execution status.

remaining_deps: AtomicUsize

Number of remaining dependencies before this task can run.

initial_deps: usize

Initial number of dependencies.

current_retry: AtomicU32

Current number of retries attempted.

Implementations

impl Task

pub fn new_static(name: &'static str, body: fn() -> Result<()>) -> Self

Create a new static task.

pub fn with_retries(self, retries: u32) -> Self

Set the number of retries for this task.

pub fn with_timeout(self, timeout: Duration) -> Self

Set a timeout for this task.