Ray
run(dag, *args[, workflow_id, metadata])
run
Run a workflow.
run_async(dag, *args[, workflow_id, metadata])
run_async
Run a workflow asynchronously.