Struct CompilationResult 

pub struct CompilationResult {
    pub coordinator: TaskSpec,
    pub steps: Vec<TaskSpec>,
    pub dependencies: HashMap<TaskId, Vec<TaskId>>,
    pub node_task_map: HashMap<NodeId, TaskId>,
    pub flow_run_id: FlowRunId,
}

The complete output of compiling a FlowSpec.

Fields

coordinator: TaskSpec

The Coordinator task spec (root of the AQ hierarchy).

steps: Vec<TaskSpec>

Step task specs, one per FlowSpec node, in topological order.

dependencies: HashMap<TaskId, Vec<TaskId>>

Dependency declarations: step TaskId -> Vec of prerequisite TaskIds.

node_task_map: HashMap<NodeId, TaskId>

Mapping from FlowSpec NodeId -> AQ TaskId for each step.

flow_run_id: FlowRunId

The FlowRunId assigned to this compilation.

Trait Implementations

impl Clone for CompilationResult

fn clone(&self) -> CompilationResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompilationResult

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

Formats the value using the given formatter.