ray.dag.output_node.MultiOutputNode.traverse_and_apply

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

Traverse all nodes in the connected component of the DAG that contains the self node, and apply the given function to each node.