ray.dag.output_node.MultiOutputNode.apply_recursive

MultiOutputNode.apply_recursive(fn: Callable[[DAGNode], T]) → T

Apply callable on each node in this DAG in a bottom-up tree walk.

Parameters:

fn – Callable that will be applied once to each node in the DAG. It will be applied recursively bottom-up, so nodes can assume the fn has been applied to their args already.

Returns:

Return type of the fn after application to the tree.