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

    // 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

        return True

    // Schedule tasks to fail initial placement group creation.
    tasks = [bothering_task.remote() for _ in range(2)]
    // Create an actor that will fail bundle scheduling.
    // It is important to use pack strategy to make test less flaky.
    pg = ray.util.placement_group(

Instances