ray.dag.compiled_dag_node.CompiledDAG.execute#

CompiledDAG.execute(*args, **kwargs) → CompiledDAGRef | List[CompiledDAGRef][source]#

Execute this DAG using the compiled execution path.

Parameters:

  • args – Args to the InputNode.

  • kwargs – Kwargs to the InputNode

Returns:

A list of Channels that can be used to read the DAG result.

Raises:

RayChannelTimeoutError – If the execution does not complete within self._submit_timeout seconds.

NOTE: Not thread-safe due to _execution_index etc.