All apps/Apache Airflow

Apache Airflow

airflow

Apache Airflow is a platform to programmatically author, schedule, and monitor workflows.

Runs as airflow|macOS, Linux, Windows|airflow.apache.org

Command form

ai-draft · 6 tasks · 18 fields

Work with DAGs and tasks. Celery, db, users, connections and other admin commands are left out.

Opens the form; the finished command lands at your prompt, unrun
otty gui airflow

airflow dags list

List DAGs

List all DAGs.

List DAGsExample values, fixed in this page — nothing here reaches a terminal
Basic
Output format
string
TasksEach one presets the form for one job
List DAGs
output
ParametersOnly these flags are editable in the form
Output format
string
--output-otablejsonyamlplain
DAG file or directory
Defaults to AIRFLOW_HOME/dags.
path
--subdir-S

airflow dags trigger

Trigger a DAG run

Trigger a run of a DAG.

Trigger a DAG runExample values, fixed in this page — nothing here reaches a terminal
Basic
DAG id*
string
Run configuration (JSON)
string
Run id
string
Execution date
string
TasksEach one presets the form for one job
Trigger a run
dag_idconfrun_idexec_date
ParametersOnly these flags are editable in the form
DAG id
string · positional 0
Run configuration (JSON)
string
--conf-c
Run id
string
--run-id-r
Execution date
string
--exec-date-e
DAG file or directory
Defaults to AIRFLOW_HOME/dags.
path
--subdir-S

airflow dags pause

Pause a DAG

Pause a DAG.

Pause a DAGExample values, fixed in this page — nothing here reaches a terminal
Basic
DAG id*
string
TasksEach one presets the form for one job
Pause
dag_id
ParametersOnly these flags are editable in the form
DAG id
string · positional 0

airflow dags unpause

Unpause a DAG

Resume a paused DAG.

Unpause a DAGExample values, fixed in this page — nothing here reaches a terminal
Basic
DAG id*
string
TasksEach one presets the form for one job
Unpause
dag_id
ParametersOnly these flags are editable in the form
DAG id
string · positional 0

airflow tasks list

List tasks of a DAG

List the tasks within a DAG.

List tasks of a DAGExample values, fixed in this page — nothing here reaches a terminal
Basic
DAG id*
string
Tree view
--tree
TasksEach one presets the form for one job
List tasks
dag_idtree
ParametersOnly these flags are editable in the form
DAG id
string · positional 0
Tree view
boolean
--tree-t
DAG file or directory
Defaults to AIRFLOW_HOME/dags.
path
--subdir-S

airflow tasks test

Test a task

Test one task instance without recording state.

Test a taskExample values, fixed in this page — nothing here reaches a terminal
Basic
DAG id*
string
Task id*
string
Execution date or run id
string
Dry run (render templates only)
--dry-run
TasksEach one presets the form for one job
Test a task
dag_idtask_idexecution_datedry_run
ParametersOnly these flags are editable in the form
DAG id
string · positional 0
Task id
string · positional 1
Execution date or run id
string · positional 2
Dry run (render templates only)
boolean
--dry-run-n
Task params (JSON)
string
--task-params-t
DAG file or directory
Defaults to AIRFLOW_HOME/dags.
path
--subdir-S
SourcesEvery flag above is checked against these
fig
completion

github.com

fig
completion

github.com

fig
completion

github.com

fig
completion

github.com

fig
completion

github.com

fig
completion

github.com

fig
completion

github.com

Before it fills your prompt, Otty checks the installed airflow against its version. A form that does not match your version is not offered.