trigger

Описание

Запускает DAG. Если DAG приостановлен, то он останется в очереди и задача не будет запущена.

Использование

$ airflow dags trigger [-h] [-c CONF] [-e EXEC_DATE] [--no-replace-microseconds]
                     [-o table, json, yaml, plain] [-r RUN_ID] [-S SUBDIR]
                     [-v]
                     dag_id

Аргументы

Параметр Описание

dag_id

Идентификатор DAG

-c, --conf

Строка JSON, которая добавляется в атрибут conf запуска DAG

-e, --exec-date

Дата исполнения DAG

--no-replace-microseconds

Следует ли обнулять микросекунды

-r, --run-id

Идентификатор запуска

-S, --subdir

Расположение файла или каталога, в котором следует искать DAG. По умолчанию [AIRFLOW_HOME]/dags, где [AIRFLOW_HOME] — это значение, которое задано для конфигурации AIRFLOW_HOME в airflow.cfg

-o, --output

Формат вывода. Возможные значения: table, json, yaml, plain. Значение по умолчанию: table

-h, --help

Вывести справку для команды

-v, --verbose

Более подробный вывод команды

Примеры

Чтобы запустить tutorial DAG, выполните:

$ airflow dags trigger tutorial

Пример вывода:

     |          |              | data_interva | data_interva |          | external_tri | last_schedul | logical_dat |          |            |
conf | dag_id   | dag_run_id   | l_end        | l_start      | end_date | gger         | ing_decision | e           | run_type | start_date | state
=====+==========+==============+==============+==============+==========+==============+==============+=============+==========+============+=======
{}   | tutorial | manual__2025 | 2025-04-04T0 | 2025-04-04T0 | None     | True         | None         | 2025-04-04T | manual   | None       | queued
     |          | -04-04T05:16 | 5:16:28+00:0 | 5:16:28+00:0 |          |              |              | 05:16:28+00 |          |            |
     |          | :28+00:00    | 0            | 0            |          |              |              | :00         |          |            |
Нашли ошибку? Выделите текст и нажмите Ctrl+Enter чтобы сообщить о ней