Struct Task 

pub struct Task<'a> {
    pub step: &'a Step,
    pub identity: &'a TaskIdentity,
    pub params: &'a Value,
    pub inputs: &'a BTreeMap<String, Value>,
    pub state: Option<&'a Value>,
    pub now_ms: u64,
}

One task instance as an operator sees it.

Fields

step: &'a Step

The step of the run, with the lease, the cancellation token and the attempt count.

identity: &'a TaskIdentity

The identity of the task instance.

params: &'a Value

The node’s parameters with every template rendered.

inputs: &'a BTreeMap<String, Value>

The output of each upstream node with a succeeded record.

state: Option<&'a Value>

The state of the previous step of the run, from its Outcome::Continue. None on the first step.

now_ms: u64

The time the step started, in milliseconds from the Unix epoch, by the clock of the store.

Trait Implementations

impl<'a> Clone for Task<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for Task<'a>

impl<'a> Debug for Task<'a>

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

Formats the value using the given formatter.