ray.workflow.run_async#

ray.workflow.run_async(dag: DAGNode, *args, workflow_id: str | None = None, metadata: Dict[str, Any] | None = None, **kwargs) → ray._raylet.ObjectRef[source]#

Run a workflow asynchronously.

If the workflow with the given id already exists, it will be resumed.

Parameters:

  • workflow_id – A unique identifier that can be used to resume the workflow. If not specified, a random id will be generated.

  • metadata – The metadata to add to the workflow. It has to be able to serialize to json.

Returns:

The running result as ray.ObjectRef.

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