ray.workflow.resume#

ray.workflow.resume(workflow_id: str) → Any[source]#

Resume a workflow.

Resume a workflow and retrieve its output. If the workflow was incomplete, it will be re-executed from its checkpointed outputs. If the workflow was complete, returns the result immediately.

Examples

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

Parameters:: workflow_id – The id of the workflow to resume.
Returns:: The output of the workflow.

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