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

    // This all should scheduled on each bundle.
    check_with_pg = [
        resource_check.options(
            placement_group=pg, placement_group_bundle_index=i).remote()
        for i in range(bundle_per_node * num_nodes)
    ]

    // Make sure these are hanging.

Instances