ada58abcd92cd7b38cf1c0ee1525d52e388558f9,python/ray/tests/test_object_spilling.py,,test_spill_objects_manually_from_workers,#Any#,68

Before Change

        ray.experimental.force_restore_spilled_objects([ref])
        assert np.array_equal(ray.get(ref), arr)

    ray.get([_worker.remote() for _ in range(50)])


def test_spill_objects_manually_with_workers(shutdown_only):

After Change

        return ref

    // Create objects of more than 200 MiB.
    replay_buffer = [ray.get(_worker.remote()) for _ in range(25)]
    values = {ref: np.copy(ray.get(ref)) for ref in replay_buffer}
    // Randomly sample objects.
    for _ in range(100):
        ref = random.choice(replay_buffer)

Instances