pub struct Job {
pub function_id: usize,
pub flow_id: usize,
pub payload: JobPayload,
pub result: Result<(Option<Value>, RunAgain)>,
pub connections: Vec<OutputConnection>,
}
Expand description
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§
§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
payload: JobPayload
the payload required to execute the job
result: Result<(Option<Value>, RunAgain)>
The result of the execution with the job_id, the optional output Value and if the function should be run again in the future
connections: Vec<OutputConnection>
The destinations (other function’s inputs) where any output should be sent
Trait Implementations§
source§impl<'de> Deserialize<'de> for Job
impl<'de> Deserialize<'de> for Job
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more