ray.workflow.获取状态

ray.workflow.get_status(workflow_id: str) → WorkflowStatus

获取给定工作流的状态。

参数:

workflow_id – 查询的工作流程。

示例

from ray import workflow

@ray.remote
def trip():
    pass

workflow_task = trip.bind()
output = workflow.run(workflow_task, workflow_id="local_trip")
assert workflow.SUCCESSFUL == workflow.get_status("local_trip")

返回:

该工作流的状态

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