0389735d7a00932433f258595e57aa87171a4927,python/ray/tests/test_reference_counting.py,,_fill_object_store_and_get,#Any#Any#Any#Any#,32

Before Change

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


def _check_refcounts(expected):
    actual = ray.worker.global_worker.core_worker.get_all_reference_counts()
    assert len(expected) == len(actual)
    for object_id, (local, submitted) in expected.items():

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