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 (Any) – Positional arguments forwarded to _execute_impl on each node.

• _ray_cache_refs (bool) – 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 (Any) – 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).

Return type:

ray._raylet.ObjectRef | ActorHandle