Size: a a a

2020 December 30

P

Pavel in Airflow
mkalinin
Всем привет. Кто подскажет как вывести стату по текущим дагам на какой нибудь порт, чтобы на него мониторинг повесить?
Если есть более эффективный вариант (более шустрый, больше возможностей для настройки мониторинга статусов), буду рад полезной ссылке )
В виде плагина ставится
источник

m

mkalinin in Airflow
Pavel
Prometheus metric exporter
Видел на гитхаб экспортера для Airflow, его рекомендуете использовать?
источник

А

Андрей in Airflow
mkalinin
В доке поискать statsd?
Можно и так
источник

m

mkalinin in Airflow
Андрей
Можно и так
Ну хотелось бы более точную ссылку)) если есть
источник

P

Pavel in Airflow
mkalinin
Видел на гитхаб экспортера для Airflow, его рекомендуете использовать?
У нас получилось вполне годный дашборд собрать, сгруппировать даги, таски. Даже по владельцам дагов можно группировать.
источник

m

mkalinin in Airflow
Pavel
У нас получилось вполне годный дашборд собрать, сгруппировать даги, таски. Даже по владельцам дагов можно группировать.
Понял, сочту за рекомендацию
источник

KP

Konstantin Petrov in Airflow
задал dags_folder, с директорией dags, после init airflow принял папку dags за airflow_home. Поправил конфиг, удалил директорию dags и при init db он опять разворчивается туда. Как можно обойти и откуда он тянет старые настройки?
источник

KP

Konstantin Petrov in Airflow
ok, export AIRFLOW_HOME=''
источник

P

Pavel in Airflow
Konstantin Petrov
задал dags_folder, с директорией dags, после init airflow принял папку dags за airflow_home. Поправил конфиг, удалил директорию dags и при init db он опять разворчивается туда. Как можно обойти и откуда он тянет старые настройки?
Директорию с дагами можно указать как в конфиг-файле, так и через переменные.
Старые настройки он ни откуда не тянет, если вы сделали init db.
источник

KP

Konstantin Petrov in Airflow
из переменной тянул
источник

C

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

Р

Руслан in Airflow
Привет. Вопрос по поводу scheduler'а.
Я же правильно понимаю, что если я устанавливаю start_date, например, в 2020-12-25 04:00 и schedule_interval в @daily, то будет запускаться начиная с 2020-12-26 каждый день в 4 утра?
источник

MS

Maksim S. in Airflow
Руслан
Привет. Вопрос по поводу scheduler'а.
Я же правильно понимаю, что если я устанавливаю start_date, например, в 2020-12-25 04:00 и schedule_interval в @daily, то будет запускаться начиная с 2020-12-26 каждый день в 4 утра?
Не верно. @daily это аналог cron 0 0 * * *
источник

Р

Руслан in Airflow
Maksim S.
Не верно. @daily это аналог cron 0 0 * * *
Тогда с 2020-12-26 каждый день в 00:00?
источник

AA

Anton Afonin in Airflow
Руслан
Тогда с 2020-12-26 каждый день в 00:00?
Каждый день в 00:00, начиная с 27.12
источник

AA

Anton Afonin in Airflow
Потому что к 26 не успеет пройти один интервал
источник

Р

Руслан in Airflow
Anton Afonin
Потому что к 26 не успеет пройти один интервал
Спасибо!
источник
2021 January 03

C

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

ДН

Дмитрий Негреев... in Airflow
кто юзает k8s executor, сколько вы минимум реквестов закладываете в под? пробовал начать с 0.1 ядра - между стартом контейнера и запуском таски почти минута проходит
больше давать не хочется, потому что задачи очень мелкие и их очень много (на 0.5 ядра celery воркера спокойно 16 тасок живут)
источник

P

Pavel in Airflow
Дмитрий Негреев
кто юзает k8s executor, сколько вы минимум реквестов закладываете в под? пробовал начать с 0.1 ядра - между стартом контейнера и запуском таски почти минута проходит
больше давать не хочется, потому что задачи очень мелкие и их очень много (на 0.5 ядра celery воркера спокойно 16 тасок живут)
Мы. Даем на большинство тасок именно по 100m
источник