Вопросы с тегом «airflow-scheduler»

Планировщик воздушного потока не запускается с kubernetes executor

Я использую https://github.com/helm/charts/tree/master/stable/airflow helm chart и создаю puckle/docker-airflowобраз v1.10.8 с установленным на нем kubernetes и использую это изображение в helm chart, но я продолжаю получать File "/usr/local/bin/airflow", line 37, in <module> args.func(args)...

Как вызвать задачу Airflow, только когда новый раздел / данные доступны в таблице athena AWS с использованием DAG в python?

У меня есть scenerio как ниже: Триггер а Task 1и Task 2только тогда, когда для них доступны новые данные в исходной таблице (Афина). Триггер для Task1 и Task2 должен произойти при новом разделении данных за день. Триггер Task 3только по завершении Task 1иTask 2 Запустить Task 4только завершениеTask...