调度 API#

调度策略#

ray.util.scheduling_strategies.PlacementGroupSchedulingStrategy(...)

Placement group based scheduling strategy.

ray.util.scheduling_strategies.NodeAffinitySchedulingStrategy(...)

Static scheduling strategy used to run a task or actor on a particular node.

占位组#

ray.util.placement_group(bundles[, ...])

Asynchronously creates a PlacementGroup.

ray.util.placement_group.PlacementGroup(id)

A handle to a placement group.

ray.util.placement_group_table([placement_group])

Get the state of the placement group from GCS.

ray.util.remove_placement_group(placement_group)

Asynchronously remove placement group.

ray.util.get_current_placement_group()

Get the current placement group which a task or actor is using.