dag-processor

Описание

Запускает автономный экземпляр процессора DAG. Вы можете выполнить эту команду с помощью действия Add/Remove components в ADCM.

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

$ airflow dag-processor [-h] [-D] [-p] [-l LOG_FILE] [-n NUM_RUNS] [--pid [PID]]
                      [--stderr STDERR] [--stdout STDOUT] [-S SUBDIR] [-v]

Аргументы

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

-D, --daemon

Запустить выполнение команды в качестве процесса-демона

-p, --do-pickle

Попытаться законсервировать объект DAG для отправки рабочим процессам вместо того, чтобы позволить рабочим процессам выполнить свою версию кода

-l, --log-file

Расположение логов

-n, --num-runs

Количество запусков, которые необходимо выполнить перед выходом. Значение по умолчанию — -1 (не делать дополнительных попыток запуска)

--pid

Расположение PID-файла

--stderr

Перенаправить stderr в указанный файл

--stdout

Перенаправить stdout в указанный файл

-S, --subdir

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

-h, --help

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

-v, --verbose

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

Нашли ошибку? Выделите текст и нажмите Ctrl+Enter чтобы сообщить о ней