Как узнать, существует ли приостановленный DAG в потоке composer или нет? - PullRequest
Новая
       69

Как узнать, существует ли приостановленный DAG в потоке composer или нет?

0 голосов
/ 14 января 2020

После загрузки файла с помощью команды GCP в папку DAG, я хотел бы проверить, создана ли DAG или нет. Могу ли я узнать команду, чтобы проверить, был ли создан приостановленный DAG или нет? В этом вопросе я упомянул «Пауза DAG», поскольку я использую конфигурацию «core-dags_are_paused_at_creation = true».

Существует load_dags, но он возвращает только не приостановленные группы DAG.

Заранее спасибо

1 Ответ

0 голосов
/ 14 января 2020

Что касается вашего вопроса, вы можете просто запросить, чтобы получить список со всеми приостановленными группами DAG, используя is_paused метод следующим образом: 

airflow=# select * from dag where is_paused;

Кроме того, в соответствии с документацией вы можете перечислить группы DAG с помощью следующей команды: 

airflow list_dags [-h] [-sd SUBDIR] [-r]

Именованные аргументы

-sd, --subdir : расположение файла или каталог, из которого нужно искать метку. По умолчанию используется значение « [AIRFLOW_HOME] / dags », где [AIRFLOW_HOME] - это значение, установленное для конфигурации «AIRFLOW_HOME», которую вы задаете в «airflow.cfg»

По умолчанию: «[AIRFLOW_HOME] / dags ”

-r, --report : Показать отчет о загрузке DagBag

По умолчанию: False

...