у нас докер по всей стране :) просто с ДФО - с часовыми поясами постоянно ерунда

UPD: разобрался вроде.
Время всех компонент должно быть в UTC для обеспечения прозрачности. В моём случае постгрес был по Москве и поэтому ничего не получалось.

Нашел параметр в конфиге, который задает интервал проверку файлов дагов на изменение. Шедулер перестал спамить бесконечными логами каждую секунду. Может кому пригодится.
# after how much time a new DAGs should be picked up from the filesystem
# после того, сколько времени новые DAG должны быть взяты из файловой системы
# 0 по умолчанию
min_file_process_interval = 180

всем привет! кто-то уже пробовал версию Airflow 1.9.0 ?

Мы пока не успели

а подробнее?

про проблемы Celery уже в курсе - кушаем полными ложками

Ну вообще кажется промежуточным на самом деле, потому что вот TriggerDagRunOperator в девелоперской версии другой, там дописаны какие-то утилиты по работе с timezones
Из того, что ещё заметил — появились дополнительные опции в командной строке ещё

Вроооде бы стали реже проблемы с самописными плагинами (у меня они стандартно плохо импортировались)

Был ещё момент с тем что он просто не запускался, пока я не указал таки сгенерированный нормальный fernet_key

доброе утро! есть информация по апрувам?

Что, до сих пор не прислали?!

Никому?

That's correct

в папке спам тоже пусто))

А киньте мне в личку ФИО ваши? Я попрошу организаторов ваши заявки побыстрее прогнать :)

Я пока в фейсбуке отписался

Передала организаторам список тех, кого нужно проаппрувить вне очереди. Они принесли извинения, что затянули, много организационных моментов. По времени не скажу, но считайте, что аппрув у вас есть :)

коллеги, кто столкнулся с проблемой работы CeleryExecutor в Airflow v1.9.0 - как я решил проблему:
1) создаем файл celeryconfig.py с содержимым:

from airflow import configuration

class CELERY_CONFIG(object):
   CELERY_ACCEPT_CONTENT = ['json', 'pickle']
   CELERY_EVENT_SERIALIZER = 'json'
   CELERY_RESULT_SERIALIZER = 'pickle'
   CELERY_TASK_SERIALIZER = 'pickle'
   CELERYD_PREFETCH_MULTIPLIER = 1
   CELERY_ACKS_LATE = True
   BROKER_URL = configuration.get('celery', 'BROKER_URL')
   CELERY_RESULT_BACKEND = configuration.get('celery', 'CELERY_RESULT_BACKEND')
   CELERYD_CONCURRENCY = configuration.getint('celery', 'CELERYD_CONCURRENCY')
   CELERY_DEFAULT_QUEUE = configuration.get('celery', 'DEFAULT_QUEUE')
   CELERY_DEFAULT_EXCHANGE = configuration.get('celery', 'DEFAULT_QUEUE')

2) копируем файл в директорию установки airflow - например, /usr/local/lib/python3.6/site-packages/airflow/celeryconfig.py
3) добавляем в airflow.cfg в раздел [celery] строку:

celery_config_options = airflow.celeryconfig.CELERY_CONFIG