ray.workflow.resume

ray.workflow.resume(workflow_id: str) → Any

恢复工作流程。

恢复工作流并检索其输出。如果工作流未完成，将从其检查点输出重新执行。如果工作流已完成，则立即返回结果。

示例

from ray import workflow

@ray.remote
def start_trip():
    return 3

trip = start_trip.bind()
res1 = workflow.run_async(trip, workflow_id="trip1")
res2 = workflow.resume("trip1")
assert ray.get(res1) == res2

参数:

workflow_id – 要恢复的工作流的ID。

返回:

工作流程的输出。

PublicAPI (alpha): 此API处于alpha阶段，可能在稳定之前发生变化。