ray.workflow.获取输出

ray.workflow.get_output(workflow_id: str, *, task_id: str | None = None) → Any

获取正在运行的工作流的输出。

参数:

• workflow_id – 获取输出结果的工作流程。

• task_id – 如果设置，则获取特定任务而不是工作流的输出。

示例

from ray import workflow

@ray.remote
def start_trip():
    return 1

trip = start_trip.options(**workflow.options(task_id="trip")).bind()
res1 = workflow.run_async(trip, workflow_id="trip1")
# you could "get_output()" in another machine
res2 = workflow.get_output("trip1")
assert ray.get(res1) == res2
task_output = workflow.get_output_async("trip1", task_id="trip")
assert ray.get(task_output) == ray.get(res1)

返回:

工作流任务的输出。

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