Как мне проверить, есть ли DAG, работающие в Airflow (перед перезапуском Airflow)?

#airflow

#воздушный поток

Вопрос:

Мне нужно перезапустить Airflow. Я хочу убедиться, что делаю это, когда он простаивает, поэтому я не прерываю работу, перезапуская рабочий компонент Airflow.

Как мне увидеть, какие базы данных запущены?

Я не вижу в пользовательском интерфейсе ничего, что указывало бы на текущие запущенные базы данных.

Я не вижу в airflow командной строке никакой команды для перечисления запущенных в данный момент баз данных.

Я обнаружил airflow shell , что это позволяет мне подключаться к БД, но я недостаточно знаю о внутренних элементах Airflow, чтобы знать, где искать, чтобы увидеть, что работает.

Ответ №1:

Вы также можете запросить базу данных, чтобы получить все запущенные задачи одновременно:

 select * from task_instance where state='running'
  

Ответ №2:

Вы можете использовать команду командной строки airflow jobs check , которая вернет «Не найдено активных заданий». в этом случае задания не выполняются.

Ответ №3:

Я нашел это … это в пользовательском интерфейсе, на странице базы данных, это второй круг в разделе «Последние задачи»:

введите описание изображения здесь