Function test_put_local_get

python/ray/tests/test_channel.py:36–50

(ray_start_regular)

    reason="Requires Linux or Mac.",
)
def test_put_local_get(ray_start_regular):
    driver_actor = create_driver_actor()
    chan = ray_channel.Channel(
        None,
        [
            (driver_actor, get_actor_node_id(driver_actor)),
        ],
        1000,
    )

    num_writes = 1000
    for i in range(num_writes):
        val = i.to_bytes(8, "little")
        chan.write(val)
        assert chan.read() == val


@pytest.mark.skipif(