- 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.
>>> from ray import workflow >>> start_trip = ... >>> 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 – The id of the workflow to resume.
The output of the workflow.
PublicAPI (alpha): This API is in alpha and may change before becoming stable.