ray.dag.output_node.MultiOutputNode#

class ray.dag.output_node.MultiOutputNode(args: List[DAGNode] | Tuple[DAGNode], other_args_to_resolve: Dict[str, Any] = None)[source]#

Bases: DAGNode

Ray dag node used in DAG building API to mark the endpoint of DAG

DeveloperAPI: This API may change across minor Ray releases.

Methods

`apply_functional`	Apply a given function to DAGNodes in source_input_list, and return the replaced inputs without mutating or coping any DAGNode.
`apply_recursive`	Apply callable on each node in this DAG in a bottom-up tree walk.
`execute`	Execute this DAG using the Ray default executor _execute_impl().
`experimental_compile`	Compile an accelerated execution path for this DAG.
`get_args`	Return the tuple of arguments for this node.
`get_kwargs`	Return the dict of keyword arguments for this node.
`get_object_refs_from_last_execute`	Gets cached object refs from the last call to execute().
`get_options`	Return the dict of options arguments for this node.
`get_other_args_to_resolve`	Return the dict of other args to resolve arguments for this node.
`get_stable_uuid`	Return stable uuid for this node.
`traverse_and_apply`	Traverse all nodes in the connected component of the DAG that contains the `self` node, and apply the given function to each node.
`with_tensor_transport`	Configure the torch tensor transport for this node.

Attributes