Size: a a a

2020 December 22

ME

Max Efremov in Airflow
Ivan Kizimenko
как лучше реализовать такую задачу:
Трекаю наличие файла с интервалом примерно 2 час.
Если файл есть то даг выполняется если нет то скипается.
Но если сегодня задача уже запустилась то мне не нужно дальше мониторить наличие этого файла
Сенсор, бранчеватель и создавать лок файл, как сделали дела сегодня, на него проверку бранчевателем
источник

IK

Ivan Kizimenko in Airflow
Max Efremov
Сенсор, бранчеватель и создавать лок файл, как сделали дела сегодня, на него проверку бранчевателем
не пойму зачем тут бранчеватель? если сам даг будет по расписанию запускаться 1 раз, далее сенсор висит и ждет файла и трекает его наличие раз в час, как только успех то даг завершается и больше не работает
источник

ME

Max Efremov in Airflow
Чтобы завершался не ошибкой при скипе
источник

ME

Max Efremov in Airflow
По крайней мере я так сделал, может есть варианты
источник

ME

Max Efremov in Airflow
Ivan Kizimenko
не пойму зачем тут бранчеватель? если сам даг будет по расписанию запускаться 1 раз, далее сенсор висит и ждет файла и трекает его наличие раз в час, как только успех то даг завершается и больше не работает
А, ну в принципе да, можно просто раз в лент запускать дагран
источник

ME

Max Efremov in Airflow
А дальше сенсор висит сутки максииум и всё
источник

IK

Ivan Kizimenko in Airflow
ну главное мысль в правильном направлении, буду разбираться как сенсор зашедулить
источник

AK

Alexander Krasnopros... in Airflow
Всем привет. Есть вопрос ) если деплоите даги в докере. То как собираете - пакуете их, собственно интересен именно пайплайн сборки от комита до прода
источник

GB

Georgy Borodin in Airflow
Alexander Krasnoproshin
Всем привет. Есть вопрос ) если деплоите даги в докере. То как собираете - пакуете их, собственно интересен именно пайплайн сборки от комита до прода
Ну всё зависит от того, что у тебя за прод. В общем виде нужно маунтить директорию с дагами, а в неё пуллить из гита
источник

AK

Alexander Krasnopros... in Airflow
Georgy Borodin
Ну всё зависит от того, что у тебя за прод. В общем виде нужно маунтить директорию с дагами, а в неё пуллить из гита
А пиповые зависимости ?

Ну и привычка со времен эксплуатации - делать идемпотетные образы.
источник

AK

Alexander Krasnopros... in Airflow
чтоб доставлять именно докер-имеджеми
источник

GB

Georgy Borodin in Airflow
Alexander Krasnoproshin
А пиповые зависимости ?

Ну и привычка со времен эксплуатации - делать идемпотетные образы.
У меня отдельная репа под airflow, отдельная – под даги
источник

GB

Georgy Borodin in Airflow
Зависимости и сборка Airflow обновляется в одном репозитории, из другого тянутся файлы дагов
источник

GB

Georgy Borodin in Airflow
Доставлять всё в одном образе тоже можно, но как-то это не круто, перезапускать всё придётся
источник

ME

Max Efremov in Airflow
Georgy Borodin
У меня отдельная репа под airflow, отдельная – под даги
Свой форк аирфлоу?
источник

GB

Georgy Borodin in Airflow
Max Efremov
Свой форк аирфлоу?
Нет конечно)
Gitlab-репка для сбора и пуша образа
источник

ME

Max Efremov in Airflow
Мы на офф имадж перешли докеровский
источник

AK

Alexander Krasnopros... in Airflow
Georgy Borodin
Зависимости и сборка Airflow обновляется в одном репозитории, из другого тянутся файлы дагов
Ну это хорошо, если можно замаунитить. А если это k8s
источник

AK

Alexander Krasnopros... in Airflow
Max Efremov
Мы на офф имадж перешли докеровский
А зависимости ?)
источник

GB

Georgy Borodin in Airflow
Alexander Krasnoproshin
Ну это хорошо, если можно замаунитить. А если это k8s
То там есть git-sync официальный
источник