ray.util.placement_group.PlacementGroup.ready

PlacementGroup.ready() → ray._raylet.ObjectRef

Returns an ObjectRef to check ready status.

Returns:

An ObjectRef that resolves once the placement group has been created and all bundles are scheduled.

Example

import ray

pg = ray.util.placement_group([{"CPU": 1}])
ray.get(pg.ready())

pg = ray.util.placement_group([{"CPU": 1}])
ray.wait([pg.ready()])