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[源代码]#

异步运行工作流。

如果具有给定ID的工作流已经存在，它将被恢复。

参数:

  • workflow_id – 一个可用于恢复工作流的唯一标识符。如果未指定，将生成一个随机ID。

  • metadata – 要添加到工作流中的元数据。它必须能够序列化为json。

返回:

运行结果为 ray.ObjectRef。

PublicAPI (alpha): 此API处于alpha阶段，可能在稳定之前发生变化。