高级主题

警告

实验性的 Ray Workflows 库已被弃用，并将在 Ray 的未来版本中移除。

跳过检查点

Ray Workflows 通过检查点提供强大的容错能力和恰好一次执行语义。然而，检查点可能会非常耗时，尤其是在工作流任务有大量输入和输出时。当不需要恰好一次执行语义时，您可以跳过一些检查点来加速工作流。

可以通过指定 checkpoint=False 来跳过检查点。

import ray
from ray import workflow

@ray.remote
def read_data(num: int):
    return [i for i in range(num)]

data = read_data.options(**workflow.options(checkpoint=False)).bind(10)

此示例跳过了对 read_data 输出的检查点。在恢复期间，如果恢复需要其输出，read_data 将会再次执行。

如果一个任务的输出是另一个任务（例如，对于动态工作流），我们将跳过对整个任务的检查点。