orka.nodes.join_node module

class orka.nodes.join_node.JoinNode(node_id, prompt, queue, memory_logger=None, **kwargs)

Bases: BaseNode

A node that waits for and merges results from parallel branches created by a ForkNode. Uses a max retry counter to prevent infinite waiting.

run(input_data)

Abstract method to run the logical node.

Parameters:

input_data – Input data for the node to process.

Raises:

NotImplementedError – If the method is not implemented by a subclass.