Struct StatefulTask 

pub struct StatefulTask { /* private fields */ }

A task whose checkpoint is loaded before, and saved after, each execution.

The checkpoint is keyed by state:{id} in the provided Storage, so a task that crashed partway through can resume from its last saved state instead of starting over. The step closure receives the previously saved state (or null on first run).

Implementations

impl StatefulTask

pub fn new<F, Fut>( id: impl Into<String>, storage: Arc<dyn Storage>, step: F, ) -> Self

where F: Fn(Arc<Context>, Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<StepResult, TaskError>> + Send + 'static,

Create a stateful task backed by storage.

pub fn with_deps<I, S>(self, deps: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Declare dependencies.

pub fn with_priority(self, priority: u8) -> Self

Set scheduling priority.

Trait Implementations

impl Task for StatefulTask

fn id(&self) -> &str

Stable, unique identifier for this task within a DAG.

fn dependencies(&self) -> Vec<String>

Ids of tasks that must complete successfully before this one runs.

fn priority(&self) -> u8

Scheduling priority; higher values are scheduled first among ready tasks.

fn execute<'life0, 'async_trait>( &'life0 self, ctx: Arc<Context>, ) -> Pin<Box<dyn Future<Output = Result<TaskOutput, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the task.