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的次要版本之间发生变化。