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

Before Change

        placement_group=pg,
        placement_group_bundle_index=num_nodes * bundle_per_node - 1).remote()
    // Destroy some nodes to fail placement group creation.
    nodes_to_kill = get_other_nodes(cluster, exclude_head=True)
    for node_to_kill in nodes_to_kill:
        cluster.remove_node(node_to_kill)

    // Wait on the placement group now. It should be unready
    // because normal actor takes resources that are required
    // for one of bundle creation.
    ready, unready = ray.wait([pg.ready()], timeout=0)
    assert len(ready) == 0
    assert len(unready) == 1

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