Все правильно, потому что первое включение генерирует базовый файл

подскажите плиз, как работает scheduler_heartbeat_sec?
в интернетах начитался что для прода лучше уменьшать его, чтоб шедулер меньше нагружен был
а на что это повлияет - не понятно

я правильно понимаю что шедулер вместо 5 секунд дефолтных начнет реже опрашивать необходимость следующие задачки запускать?
например у меня таска из дага выполнилась, а следующая может начать только через минуту (если я например с 5 на 60 секунд параметр изменю)

привет
не подскажите

Traceback (most recent call last):
 File "/usr/local/bin/airflow", line 25, in <module>
   from airflow.configuration import conf
 File "/usr/local/lib/python3.6/dist-packages/airflow/__init__.py", line 97, in <module>
   operators._integrate_plugins()
 File "/usr/local/lib/python3.6/dist-packages/airflow/operators/__init__.py", line 104, in _integrate_plugins
   from airflow.plugins_manager import operators_modules, register_inbuilt_operator_links
 File "/usr/local/lib/python3.6/dist-packages/airflow/plugins_manager.py", line 194, in <module>
   plugins
 File "/usr/local/lib/python3.6/dist-packages/airflow/plugins_manager.py", line 104, in load_entrypoint_plugins
   plugin_obj = entry_point.load()
 File "/home/ubuntu/.local/lib/python3.6/site-packages/pkg_resources/__init__.py", line 2460, in load
   self.require(*args, **kwargs)
 File "/home/ubuntu/.local/lib/python3.6/site-packages/pkg_resources/__init__.py", line 2483, in require
   items = working_set.resolve(reqs, env, installer, extras=self.extras)
 File "/home/ubuntu/.local/lib/python3.6/site-packages/pkg_resources/__init__.py", line 791, in resolve
   raise VersionConflict(dist, req).with_context(dependent_req)
pkg_resources.ContextualVersionConflict: (tzlocal 2.1 (/home/ubuntu/.local/lib/python3.6/site-packages), Requirement.parse('tzlocal<2.0.0,>=1.4'), {'apache-airflow'})



подозреваю что из-за конфликта версий питона

Написано же проблема с версией tzlocal 2.1

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

а как ее решить? переустановить или как

Поставить требуемую версию

Там написано, надо выше или равно 1.4 и ниже 2.0

cпасибо помогло

Добрый день!
Кто нибудь сталкивался с ошибкой cryptography.fernet.InvalidToken при использовании PostgresHook внутри PythonOperator?
при этом, если в dag добавлять PostgresOperator с тем же conn_id - всё работает

Всем привет! Я новичок в airflow. Возвращает ошибку.  python_callable param must be callable
Подскажите, куда капать?

туда надо функцию)

так я функцию и передаю)

видимо как-то не совсем так, раз питон её ща функцию не считает

Нужен код, но почти наверняка дело в том, что надо убрать скобочки)

спасибо @Tmin10_work
имя функции совпадало с именем оператора

Подскажите, а почему когда из контекста таски считываю даг, у него старт дейт стоит None? Приходится читать дефолтные аргументы и оттуда дату начала дага брать

Всем привет. Подскажите, пожалуйста, по такому вопросу. Есть web server, scheduler, которые запущены каждый в своем контейнере и смотрят на даги через смонтированные папки. После того, как добавлен новый даг, он появляется, но не запускается, скорее всего не работает scheduler, просто не подхватывается. Что в таком случае делать? Только контейнер с нуля перезапускать?

А он автоматом включается?