Size: a a a

2020 August 26

Р

Роман in Airflow
Mikhail
--reset_dagruns
👍
источник
2020 August 27

C

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

VA

Vladislav Akatov in Airflow
Кто-нибудь испытывал проблему: в LocalExecutor при ошибке в тасках scheduler перестает работать и возвращает
The scheduler does not appear to be running.
источник

ДН

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

CO

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

PA

Panchenko Andrey in Airflow
посмотреть где
источник

PA

Panchenko Andrey in Airflow
?
источник

PA

Panchenko Andrey in Airflow
источник

CO

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

PA

Panchenko Andrey in Airflow
екстернал триггер даг?
источник

PA

Panchenko Andrey in Airflow
ааа
источник

PA

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

PA

Panchenko Andrey in Airflow
но его нужно поставить
источник

CO

Chern Oleksander in Airflow
Panchenko Andrey
я думаю что тут нужно в stat смотреть если програмно
чет не могу доку найти, можно чет в меня кинуть?
источник

CO

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

ME

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

m

mechanik in Airflow
Дмитрий Негреев
Возможно ли как-то template_fields вынести на уровень оператора?
Приходится парсить конфиг, где указан путь к файлу (в тексте которого есть шаблоны) в top level коде дага.
Для этого есть ещё template_ext на уровне оператора и template_searchpath на уровне dag.
источник
2020 August 28

ДН

Дмитрий Негреев... in Airflow
mechanik
Для этого есть ещё template_ext на уровне оператора и template_searchpath на уровне dag.
Насколько я понял, эти поля помогают искать файл, если он у тебя не в dag_folder лежит, и ты ему расширение не указал
источник

ДН

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

VN

Vova Narovchatskiy in Airflow
Всем привет!

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

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

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