execute

CompiledDAG.execute(*args: Any, **kwargs: Any) → CompiledDAGRef | List[CompiledDAGRef]

Execute this DAG using the compiled execution path.

Parameters:

• *args (Any) – Args to the InputNode.

• **kwargs (Any) – 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.

Return type:

CompiledDAGRef | List[CompiledDAGRef]

NOTE: Not thread-safe due to _execution_index etc.