Struct Task 

pub struct Task<P> { /* private fields */ }

A task to submit. Wraps TaskSpec and resolves times at submission.

Implementations

impl<P> Task<P>

pub fn new(payload: P) -> Self

A task with default settings: pool and kind "default", priority Normal.

pub fn from_arc(payload: Arc<P>) -> Self

Like Task::new, sharing an existing Arc payload.

pub fn spec(&self) -> &TaskSpec<P>

The underlying engine spec (times given relatively are resolved at submission).

pub fn kind(self, k: impl Into<Arc<str>>) -> Self

Task kind: groups tasks for duration learning, metrics and tracing.

pub fn pool(self, p: impl Into<Arc<str>>) -> Self

Pool to run in (default "default").

pub fn priority(self, p: Priority) -> Self

Priority class (default Normal).

pub fn key(self, k: impl Into<Arc<str>>) -> Self

Unique key: deduplicates submissions and can be referenced by dependents.

pub fn deadline_in(self, d: Duration) -> Self

Soft deadline, relative to submission: urgency rises as it approaches.

pub fn deadline_at(self, t: SystemTime) -> Self

Soft deadline at a wall-clock time.

pub fn start_at(self, t: SystemTime) -> Self

Start at a fixed time (default tolerance 1s, run late if missed).

pub fn start_in(self, d: Duration) -> Self

Start this long after submission (default tolerance 1s, run late if missed).

pub fn start_tolerance(self, tol: Duration) -> Self

How late a fixed start may begin and still count as on time (any call order).

pub fn on_miss(self, p: MissPolicy) -> Self

What to do if the fixed start is missed (any call order).

pub fn duration_hint(self, d: Duration) -> Self

Expected run time, used before the engine has learned the kind’s durations.

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

Per-attempt timeout: the attempt is aborted and retried (if allowed) when it elapses.

pub fn retry(self, r: RetryPolicy) -> Self

Retry policy (default: the pool’s).

pub fn no_retry(self) -> Self

Run at most once.

pub fn after(self, target: impl Into<TaskRef>) -> Self

Run after target succeeds.

pub fn dep(self, d: Dep) -> Self

Add a dependency with an explicit edge condition.

pub fn resource(self, name: impl Into<Arc<str>>, amount: u32) -> Self

Require amount units of a configured resource for each attempt.

pub fn tag(self, k: impl Into<Arc<str>>, v: impl Into<Arc<str>>) -> Self

Attach a key/value label (visible to executors and in traces).

pub fn tenant(self, tenant: impl Into<Arc<str>>) -> Self

The tenant this task belongs to, for weighted fair sharing of pools with PoolConfig::fairness.

pub fn label( self, name: impl Into<Arc<str>>, value: impl Into<Arc<str>>, ) -> Self

Run only on workers labeled name = value (see Scheduler::set_group_capacity).

Trait Implementations

impl<P> Clone for Task<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for Task<P>

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

Formats the value using the given formatter.

impl<P> From<TaskSpec<P>> for Task<P>

fn from(spec: TaskSpec<P>) -> Self

Converts to this type from the input type.