ray.dag.input_node.InputNode.traverse_and_apply

InputNode.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.