orkes.graph.ParallelEdge

class orkes.graph.ParallelEdge(from_node, to_nodes, aggregation_node, max_passes=25)

An edge that creates multiple parallel branches of execution.

Each branch starts from a node in to_nodes. All branches are expected to eventually converge at the aggregation_node.

Parameters:

• from_node (NodePoolItem)

• to_nodes (list[NodePoolItem])

• aggregation_node (NodePoolItem)

• max_passes (int)

__init__(from_node, to_nodes, aggregation_node, max_passes=25)

Initializes a ParallelEdge.

Parameters:

• from_node (NodePoolItem) – The node from which the edge originates.

• to_nodes (list[NodePoolItem]) – A list of nodes where each parallel branch starts.

• aggregation_node (NodePoolItem) – The node where all parallel branches are expected to converge.

• max_passes (int, optional) – The maximum number of times this edge can be traversed. Defaults to 25.

Methods

__init__(from_node, to_nodes, aggregation_node)

Initializes a ParallelEdge.