dcb9e03fde3116f7c43787947ea6f0b37ddb3210,python/ray/tests/test_placement_group.py,,test_atomic_creation,#Any#,620

Before Change

    assert len(unready) == 1

    // Add a node back to schedule placement group.
    for _ in range(len(nodes_to_kill)):
        nodes.append(
            cluster.add_node(num_cpus=bundle_cpu_size * bundle_per_node))
    // Wait on the placement group creation.
    ready, unready = ray.wait([pg.ready()])
    assert len(ready) == 1
    assert len(unready) == 0

After Change

    def pg_removed():
        return ray.util.placement_group_table(pg)["state"] == "REMOVED"

    wait_for_condition(pg_removed)

    // Make sure check without pgs are all
    // scheduled properly because resources are cleaned up.
    assert all(ray.get(check_without_pg))

Instances