ray.experimental.compiled_dag_ref.CompiledDAGRef

class ray.experimental.compiled_dag_ref.CompiledDAGRef(dag: ray.experimental.CompiledDAG, execution_index: int, channel_index: int | None = None)

A reference to a compiled DAG execution result.

This is a subclass of ObjectRef and resembles ObjectRef. For example, similar to ObjectRef, ray.get() can be called on it to retrieve the result. However, there are several major differences: 1. ray.get() can only be called once per CompiledDAGRef. 2. ray.wait() is not supported. 3. CompiledDAGRef cannot be copied, deep copied, or pickled. 4. CompiledDAGRef cannot be passed as an argument to another task.

PublicAPI (alpha): This API is in alpha and may change before becoming stable.

Methods

__init__

param dag: The compiled DAG that generated this CompiledDAGRef.