Документация по воздушному потоку гласит: Воздушный поток предоставляет экспериментальный API...

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

У меня есть DAG, у него 5 заданий A, B, C, D, E.и 5 заданий, вызванных вышеперечисленными...

в Airflow я пытаюсь использовать шаблон jinja в airflow, но проблема в том, что он не анализируется...

Есть ли способ запустить subdag как задачу?То есть, когда задача в подпадаре завершается неудачей,...

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

У меня есть настройка воздушного потока с default_timezone = US/Eastern.Если я установлю DAG с...

Для Airflow я использую mysql DB.У меня нет дагов, несколько даг собираются начать одновременно,...

Я новичок в воздушном потоке, мне удалось его запустить и запустить, и я могу получить доступ к...

Поток воздуха внезапно прекратил выполнение задач. Ниже все бегут airflow scheduler airflow...

Я использую Airflow 1.8 на хосте CentOS, который является частью кластера Cloudera. При переходе в...

Я пытаюсь запустить DAG из REST API и передать ему некоторые параметры.Группа обеспечения...

Является ли значение execution_date датой / временем времени, когда группа обеспечения доступности...

Я загружаю файл DAG на веб-страницу, и когда я нажимаю 'Graph View' -> ${my_dag} ->...

Я читаю этот вопрос , пытаясь реализовать зависимости от задач других DAG s. В этом примере...

Я все еще в процессе развертывания Airflow, и я уже почувствовал необходимость объединения operator...

В настоящее время я настроил планировщик воздушного потока на сервере Linux A и веб-сервер...

У меня есть следующий код на Airflow 1.9: import_op = MySqlToGoogleCloudStorageOperator(...

Я только начал изучать Apache Airflow. Есть ли способ запустить задание, которое изучит работающие...

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

Я хочу добавить расписание (каждую пятницу в 8:00) в DAG. Ниже мой конфиг для DAG: DAG CONFIG: args...

У меня есть 6 подзадач. Каждый из них содержит задачу с pool='crawler', которая требует...

Когда я создаю новый ярлык, я должен зайти в пользовательский интерфейс и щелкнуть переключатель...

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

import airflow from airflow import DAG from airflow.operators.python_operator import PythonOperator...