bdc6624da8848fbd1bf370f22ce0947b3c9dca6a,python/ray/tests/test_placement_group.py,,test_create_placement_group_during_gcs_server_restart,#Any#,1233

Before Change

    cluster.head_node.start_gcs_server()

    for i in range(0, 100):
        assert placement_groups[i].wait(10000)


def test_placement_group_wait_api(ray_start_cluster):
    cluster = ray_start_cluster

After Change

    cluster.head_node.start_gcs_server()

    for i in range(0, 100):
        ray.get(placement_groups[i].ready())


if __name__ == "__main__":
    sys.exit(pytest.main(["-v", __file__]))

Instances