Всем привет. Кто подскажет как вывести стату по текущим дагам на какой нибудь порт, чтобы на него мониторинг повесить? Если есть более эффективный вариант (более шустрый, больше возможностей для настройки мониторинга статусов), буду рад полезной ссылке )
задал dags_folder, с директорией dags, после init airflow принял папку dags за airflow_home. Поправил конфиг, удалил директорию dags и при init db он опять разворчивается туда. Как можно обойти и откуда он тянет старые настройки?
задал dags_folder, с директорией dags, после init airflow принял папку dags за airflow_home. Поправил конфиг, удалил директорию dags и при init db он опять разворчивается туда. Как можно обойти и откуда он тянет старые настройки?
Директорию с дагами можно указать как в конфиг-файле, так и через переменные. Старые настройки он ни откуда не тянет, если вы сделали init db.
Привет. Вопрос по поводу scheduler'а. Я же правильно понимаю, что если я устанавливаю start_date, например, в 2020-12-25 04:00 и schedule_interval в @daily, то будет запускаться начиная с 2020-12-26 каждый день в 4 утра?
Привет. Вопрос по поводу scheduler'а. Я же правильно понимаю, что если я устанавливаю start_date, например, в 2020-12-25 04:00 и schedule_interval в @daily, то будет запускаться начиная с 2020-12-26 каждый день в 4 утра?
кто юзает k8s executor, сколько вы минимум реквестов закладываете в под? пробовал начать с 0.1 ядра - между стартом контейнера и запуском таски почти минута проходит больше давать не хочется, потому что задачи очень мелкие и их очень много (на 0.5 ядра celery воркера спокойно 16 тасок живут)
кто юзает k8s executor, сколько вы минимум реквестов закладываете в под? пробовал начать с 0.1 ядра - между стартом контейнера и запуском таски почти минута проходит больше давать не хочется, потому что задачи очень мелкие и их очень много (на 0.5 ядра celery воркера спокойно 16 тасок живут)