Workflow Management API#

resume(workflow_id)

Resume a workflow.

resume_async(workflow_id)

Resume a workflow asynchronously.

resume_all([include_failed])

Resume all resumable workflow jobs.

list_all([status_filter])

List all workflows matching a given status filter.

get_status(workflow_id)

Get the status for a given workflow.

get_output(workflow_id, *[, task_id])

Get the output of a running workflow.

get_output_async(workflow_id, *[, task_id])

Get the output of a running workflow asynchronously.

get_metadata(workflow_id[, task_id])

Get the metadata of the workflow.

cancel(workflow_id)

Cancel a workflow. Workflow checkpoints will still be saved in storage. To