0389735d7a00932433f258595e57aa87171a4927,python/ray/tests/test_reference_counting_2.py,,_fill_object_store_and_get,#Any#Any#Any#Any#,35

Before Change

    if succeed:
        ray.get(oid)
    else:
        with pytest.raises(ray.exceptions.RayTimeoutError):
            ray.get(oid, timeout=0.1)


// Test that an object containing object IDs within it pins the inner IDs
// recursively and for submitted tasks.
@pytest.mark.parametrize("use_ray_put,failure", [(False, False), (False, True),
                                                 (True, False), (True, True)])
def test_recursively_nest_ids(one_worker_100MiB, use_ray_put, failure):
    @ray.remote(max_retries=1)

After Change

        oid = ray.ObjectID(oid)

    if succeed:
        wait_for_condition(
            lambda: ray.worker.global_worker.core_worker.object_exists(oid))
    else:
        wait_for_condition(
            lambda: not ray.worker.global_worker.core_worker.object_exists(oid)
        )

Instances