ray.experimental.compiled_dag_ref.CompiledDAGRef.__init__#

CompiledDAGRef.__init__(dag: ray.experimental.CompiledDAG, execution_index: int, channel_index: int | None = None)[source]#

Initialize a CompiledDAGRef.

Parameters:

  • dag – The compiled DAG that generated this CompiledDAGRef.

  • execution_index – The index of the execution for the DAG. A DAG can be executed multiple times, and execution index indicates which execution this CompiledDAGRef corresponds to.

  • channel_index – The index of the DAG’s output channel to fetch the result from. A DAG can have multiple output channels, and channel index indicates which channel this CompiledDAGRef corresponds to. If channel index is not provided, this CompiledDAGRef wraps the results from all output channels.