ray.workflow.resume_async

ray.workflow.resume_async(workflow_id: str) → ray._raylet.ObjectRef

异步恢复工作流程。

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

示例

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_async("trip1")
assert ray.get(res1) == ray.get(res2)

参数:

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

返回:

一个可用于检索工作流结果的对象引用。

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