Struct flowrlib::job::Job

pub struct Job {
    pub job_id: usize,
    pub function_id: usize,
    pub flow_id: usize,
    pub input_set: Vec<Value>,
    pub connections: Vec<OutputConnection>,
    pub implementation: Arc<dyn Implementation>,
    pub result: Result<(Option<Value>, RunAgain)>,
}

A Job contains the information necessary to manage the execution of a function in the flow on a set of input values, and then where to send the outputs that maybe produces.

Fields

job_id: usize

Each Job has a unique id that increments as jobs are executed

function_id: usize

The id of the function in the RunState’s list of functions that will execute this job

flow_id: usize

The id of the nested flow (from root flow on down) there the function executing the job is

input_set: Vec<Value>

The set of input values to be used by the function when executing this job

connections: Vec<OutputConnection>

The set of destinations (other function’s inputs) where the output produced by the function should be sent

implementation: Arc<dyn Implementation>

The implementation to be used in executing the job

result: Result<(Option<Value>, RunAgain)>

The result of the execution with optional output Value and if the function should be run again in the future

Trait Implementations

impl Clone for Job

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'de> Deserialize<'de> for Job

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Display for Job

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

Formats the value using the given formatter.

impl Serialize for Job

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.