Я хочу использовать DAG с воздушным потоком для запуска некоторых заданий. Я запланировал выражение...

Я знаю, что есть способ удалить DAG. Но возможно ли удалить прогон DAG с конкретным run_id? Что-то...

Возникла проблема, когда при установке airflow (в python3) не создается каталог airflow (в отличие...

У нас около 20 дагов, и у каждого даг около 6 заданий. Во время выполнения воздушный поток занимает...

* TLDR : Этот вопрос изначально был основан на проблеме, которая была позже определена как...

Каков наилучший способ хранения разъемов RSA в разъемах Airflow? hook = BaseHook

Есть ли способ для Airflow пропустить текущую задачу из (Python) оператора? Например: def...

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

У меня есть рабочий процесс ниже. Что я хочу сделать, так это запустить задачу join, если все...

Попытка использовать EmailOperator airflow для отправки электронного письма на trigger_rule

У меня Apache-Airflow реализован на сервере Ubuntu версии 18.04.3. Когда я его настраивал, я...

Если я не настраиваю ведение журнала (не настраиваемое ведение журнала) в Apache Airflow (1.10.5),...

Я пытаюсь найти наиболее общий / эффективный способ передачи переменных из одной задачи...

Когда я пытался удалить значок в веб-интерфейсе, получалось: Dag id zhihu_qr_dag is still in DagBag

Я использую док-станцию ​​Jenkins вместе с потоком воздуха на моей локальной машине. Задание...

Я ищу эффективный способ разработки плагинов в Airflow. Текущее поведение: я что-то изменяю в...

My Airflow dag отправляет запрос HTTP PUT каждый час с указанием часа в теле. В случае неудачи я...

Так что я боролся с этим часами. Это код моего оператора: task1 = GKEPodOperator(...

Я использую Airflow 1.10.5. Не могу найти полную документацию или пример того, как настроить...

Я хочу запустить dag, который содержит 2 задачи в цикле, скажем, 1..10. Одним из способов является...

Я знаю, что можно повторить отдельные задачи, но можно ли повторить попытку завершить DAG? Я создаю...

Я довольно плохо знаком с потоком воздуха и пытаюсь запускать процесс ETL каждые 5 минут. У меня...

Я пытаюсь обновить БД с помощью команды «airflow upgradededb» в версии 1.10.2. Мой вопрос...

Я хочу запустить простой Dag "test_update_bq", но когда я иду на localhost, я вижу это: DAG...

Я запускаю поток воздуха в Kubernetes и использую «Оператор Kubernetes» . Когда я запускаю...