ray.workflow.取消

ray.workflow.cancel(workflow_id: str) → None

取消一个工作流程。工作流程检查点仍将保存在存储中。

清理保存的检查点，参见 workflow.delete()。

参数:

workflow_id – 取消的工作流程。

示例

from ray import workflow

@ray.remote
def some_job():
   return 1

workflow_task = some_job.bind()
workflow.run(workflow_task, workflow_id="some_job")
workflow.cancel(workflow_id="some_job")
assert workflow.get_status("some_job") == workflow.CANCELED

返回:

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