ray.workflow.get_status#

ray.workflow.get_status(workflow_id: str) → WorkflowStatus[source]#

Get the status for a given workflow.

Parameters:: workflow_id – The workflow to query.

Examples

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")

Returns:: The status of that workflow

PublicAPI (alpha): This API is in alpha and may change before becoming stable.