run

Елена Костюченко

Описание

Запускает один экземпляр задачи в DAG.

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

$ airflow tasks run [-h] [--cfg-path CFG_PATH] [-d {ignore,wait,check}] [-f]
                  [-A] [-i] [-I] [-N] [-l] [--map-index MAP_INDEX] [-m]
                  [-p PICKLE] [--pool POOL] [--read-from-db] [--ship-dag]
                  [-S SUBDIR] [-v]
                  dag_id task_id execution_date_or_run_id

Аргументы

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

dag_id

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

task_id

Идентификатор задачи

execution_date_or_run_id

execution_date группы DAG или run_id запуска группы DAG

--cfg-path

Путь к файлу конфигурации, который следует использовать вместо airflow.cfg

-d, --depends-on-past

Метод работы Airflow с зависимостями. Возможные варианты:

  • check (по умолчанию) — Airflow проверит, выполнены ли зависимости для задач, имеющих depends_on_past=True, перед их запуском.

  • ignore — игнорировать зависимости.

  • wait — если depends_on_past=True, Airflow будет ждать, пока не будут выполнены прошлые зависимости, прежде чем запустить или пропустить задачу.

-f, --force

Игнорировать предыдущее состояние экземпляра задачи. Перезапустить независимо от того, была ли задача уже выполнена успешно или нет

-A, --ignore-all-dependencies

Игнорирует все некритические зависимости, включая ignore_ti_state и ignore_task_deps

-i, --ignore-dependencies

Игнорировать зависимости, специфичные для задач. Например, upstream, depend_on_past и зависимости задержки повторного выполнения (retry delay)

-I, --ignore-depends-on-past

Устаревшая опция. Вместо этого используйте -–depends-on-past ignore

-N, --interactive

Не захватывать стандартный вывод и потоки ошибок (полезно для интерактивной отладки)

-l, --local

Запустить задачу с помощью LocalExecutor

--map-index

Индекс сопоставленной задачи

-m, --mark-success

Отметить задания как выполненные, не запуская их

-p, --pickle

Сериализованный объект pickle всего DAG (для внутреннего использования)

--pool

Пул ресурсов для использования

--read-from-db

Читать DAG из БД вместо DAG-файла

--ship-dag

Выполнить сериализацию DAG и отправить его рабочему процессу

-S, --subdir

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

-h, --help

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

-v, --verbose

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

Примеры

Пример команды для отдельного запуска задачи:

$ airflow tasks run tutorial print_date 2025-04-04
Нашли ошибку? Выделите текст и нажмите Ctrl+Enter чтобы сообщить о ней