Module: MARS::Rendering::Graph::ParallelWorkflow

Includes:
Base
Defined in:
lib/mars/rendering/graph/parallel_workflow.rb

Instance Method Summary collapse

Methods included from Base

#build_graph, #node_id

Instance Method Details

#to_graph(builder, parent_id: nil, value: nil) ⇒ Object 



9
10
11
12
13
14
15
16
 
# File 'lib/mars/rendering/graph/parallel_workflow.rb', line 9

def to_graph(builder, parent_id: nil, value: nil)
  builder.add_subgraph(node_id, name) if steps.any?
  builder.add_node(aggregator.node_id, aggregator.name, Node::STEP)

  build_steps_graph(builder, parent_id, value)

  [aggregator.node_id]
end