- 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.