ray.data.ExecutionOptions#

class ray.data.ExecutionOptions(resource_limits: ExecutionResources | None = None, exclude_resources: ExecutionResources | None = None, locality_with_output: bool | List[str] = False, preserve_order: bool = False, actor_locality_enabled: bool = False, verbose_progress: bool | None = None)[源代码]#

基类:object

执行的常用选项。

某些选项可能并非在所有执行器上都支持(例如,资源限制)。

resource_limits#

在执行期间设置资源使用的软限制。默认情况下自动检测。

exclude_resources#

从 Ray Data 中排除的资源量。如果你在同一集群上运行其他工作负载,请设置此项。注意,- 如果将 Ray Data 与 Ray Train 一起使用,训练资源将自动排除。- 对于每种资源类型,不能同时设置 resource_limits 和 exclude_resources。

locality_with_output#

将此设置为优先在输出节点(驱动执行的节点)所在的同一节点上运行任务。也可以将其设置为节点ID列表,以在这些节点之间分配输出。默认关闭。

preserve_order#

设置此项以保留由操作符处理的块之间的顺序。默认关闭。

actor_locality_enabled#

是否启用本地化任务分派给执行者(默认关闭)。此参数适用于有状态映射和流式分割操作。

verbose_progress#

是否为每个操作符单独报告进度。默认情况下,只报告 AllToAll 操作符和全局进度。此选项对性能调试很有用。默认开启。

开发者API: 此API可能会在Ray的次要版本之间发生变化。

is_resource_limits_default()[源代码]#

如果 resource_limits 是默认值,则返回 True。

validate() None[源代码]#

验证选项。