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)

Run the join operation by collecting and merging results from forked agents.