ray.dag.output_node.MultiOutputNode.execute#

MultiOutputNode.execute(*args: Any, _ray_cache_refs: bool = False, **kwargs: Any) ray._raylet.ObjectRef | ActorHandle#

Execute this DAG using the Ray default executor _execute_impl().

Parameters:
  • *args – Positional arguments forwarded to _execute_impl on each node.

  • _ray_cache_refs – If true, stores the default executor’s return values on each node in this DAG in a cache. These should be a mix of: - ray.ObjectRefs pointing to the outputs of method and function nodes - Serve handles for class nodes - resolved values representing user input at runtime

  • **kwargs – Keyword arguments forwarded to _execute_impl on each node.

Returns:

The result of executing the DAG (an ObjectRef or an ActorHandle depending on the root node type).