👍

Добро пожаловать в самое дружелюбное комьюнити.

Кто-нибудь испытывал проблему: в LocalExecutor при ошибке в тасках scheduler перестает работать и возвращает

The scheduler does not appear to be running.

Возможно ли как-то template_fields вынести на уровень оператора?
Приходится парсить конфиг, где указан путь к файлу (в тексте которого есть шаблоны) в top level коде дага.

Всем привет, вроде подымалась тема в чатике, но не могу найти
Как можно посмотреть статус дага ?

посмотреть где

?

Согласен, из функции узнать
Например у меня есть 10 функций внутри, которые работают каждые 3и часа
Мне нужно во втором часу узнать был ли блок функций выполнен(5 функций), если да - выполнить другое действие

екстернал триггер даг?

ааа

я думаю что тут нужно в stat смотреть если програмно

но его нужно поставить

чет не могу доку найти, можно чет в меня кинуть?

в моем случае делаю через xcom когда даг отрабатывает пишу в xcom, потом при повторном проходе смотрю на определеной функции, если всё прошло, тогда формирую датасет

А кто-то airflow с vault дружил, чтобы креды получать оттуда? Для базы подключение и для коннектов было бы тоже полезно

Для этого есть ещё template_ext на уровне оператора и template_searchpath на уровне dag.

Насколько я понял, эти поля помогают искать файл, если он у тебя не в dag_folder лежит, и ты ему расширение не указал

Но все-равно нужно указывать в операторе название файла как входной параметр.
Или он просто список найденных файлов выдаст?

Всем привет!

Не получается настроить работу impersonation.  Когда указываем run_as_user, выдает ошибку  sudo: airflow: command not found .
Может быть кто сталкивался с таким?

Ошибка похожа на ту, когда юзается не та версия питона. Если делаю вывод версии баш оператором, то получаю совершенно не ту (2.7.5), на которой эйрфлоу работает (3.6.9)

Пробовал настроить для определенного unix пользователя, чтобы по дефоулту при старте включался нужный питон (прописал это в .bashrc и .bash_profile), но это также не помогло