Выполнить код при запуске в Airflow - PullRequest
0 голосов
/ 30 мая 2018

Есть ли способ, как я могу выполнить какой-то код только один раз после запуска Airflow?Я хотел бы настроить способ ведения журнала, но не могу найти способ инициализации этой конфигурации только один раз ...

from utils import logger
logger.initialize()

Это в основном эти строки (utils - это локально определенный пакет),Это работает, когда я помещаю эти строки в одну из групп доступности баз данных, но затем функция выполняется несколько раз, что не нужно ...

1 Ответ

0 голосов
/ 01 июня 2018

Создайте модуль с именем airflow_local_settings, который можно импортировать глобально.airflow.settings воздушного потока пытается загрузить модуль во время запуска.

...