工作流执行 API#

run(dag, *args[, workflow_id, metadata])

运行一个工作流程。

run_async(dag, *args[, workflow_id, metadata])

异步运行工作流。