У меня есть группа доступности базы данных, которую я хочу использовать для обратной заполнения...

Я использую Apache Airflow версии 1.9.0, и когда я пытаюсь запустить задачу из пользовательского...

Я использую Local Executor. У меня есть ситуация, когда у меня есть уникальные пакеты, генерируемые...

Я создал функцию on_failure_callback (ссылаясь на Воздушный поток по умолчанию on_failure_callback...

API в Airflow, похоже, предполагает, что он построен на основе обратной засыпки, отслеживания и...

Мне удалось успешно визуализировать шаблоны Jinja, используя функцию в BaseOperator,...

Я могу настроить файл airflow.cfg для запуска задач один за другим. Что я хочу сделать, так это...

Я пробую воздушный поток с BigQueryOperator. Я думал, что позже буду использовать Google Composer,...

Я установил поток воздуха и пытаюсь запустить рабочий на Mac. Но я получаю следующую ошибку. Не...

У меня есть несколько неудачных DAG, скажем, с 1 по 20 февраля. С этой даты все они преуспели. Я...

Похоже, что вы можете получить доступ к параметрам конфигурации dag_run, используя PythonOperator и...

Похоже, у Airflow есть экспериментальный API REST, который позволяет пользователям создавать...

Я очень плохо знаком с потоком воздуха. Мой поток воздуха работает нормально уже много дней. Мне...

Я использую воздушный поток 1.8.1, и было поведение проводной, и я попытался выяснить. Случилось...

У меня есть требование, когда есть родительский Dag только с одной задачей, которая создает...

Можно ли вызвать сбой DAG Airflow в случае сбоя какой-либо задачи? У меня обычно есть некоторые...

У меня есть свой собственный пользовательский оператор, расширяющий BaseOperator следующим образом....

Правило триггера "all_done" не работает, когда его родители помечены как State.None вместо State

Я недавно обновился с v1.7.1.2 до v1.9.0 и после обновления заметил, что загрузка ЦП значительно...