Function create_driver_actor

python/ray/tests/test_channel.py:24–29

()

def create_driver_actor():
    return CompiledDAG.DAGDriverProxyActor.options(
        label_selector={
            ray._raylet.RAY_NODE_ID_KEY: ray.get_runtime_context().get_node_id()
        }
    ).remote()


@pytest.mark.skipif(