ray.workflow.resume_async(workflow_id: str) ray.ObjectRef[source]#

Resume a workflow asynchronously.

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.


An object reference that can be used to retrieve the workflow result.

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