Можно ли с помощью Airflow перезапустить задачу вверх по потоку, если задача внизу не выполняется?...

У меня DAG работает каждые 30 минут. Скажите, что это DAG (для простоты используются фиктивные...

Я пытаюсь использовать Cloud Composer для запуска моего рабочего процесса. Я хотел использовать...

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

Настройки Windows 10 Python 3.6 Visual Studio 2017 Для воссоздания вопроса $set...

Мой DAG выводит некоторые данные из базы данных и сохраняет их в локальном файле. Другие задачи (в...

У меня есть потоковое задание flink, которое читает из Kafka и записывает в соответствующие разделы...

Я пытаюсь интегрировать аутентификацию Airflow Webserver с RBAC Flask-AppBuilder, доступным в...

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

Я использую облачный композитор для организации ETL для файлов, поступающих в GCS и отправляемых в...

Ниже приведена простая копия созданной мной группы DAG. Группа обеспечения доступности баз данных...

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

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

Попытка выполнить запрос с помощью pythonoperator (используя BigQueryHook) def...

Я пытаюсь запустить PythonVirtualenvOperator в dag в gcloud composer среде, но получаю ошибку при...

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

Я настроил Airflow на SQL Server в качестве бэкэнда (SQL Azure). Инициализация DB успешно завершена

В этом сообщении блога : from airflow import DAG from datetime import datetime, timedelta from...

У меня есть кластер gce airflow (composer) с кучей рабочих: $ kubectl get pods NAME READY STATUS...

Как установить соединение между главным кластером EMR (созданным Terraform) и Airflow. У меня...

У меня есть требование найти количество времени по любой конкретной задаче в DAG . Например:...

Я хотел бы иметь возможность доступа к данным на листе Google при запуске кода Python через...

Я написал следующий скрипт DAG (код Python), который запускает BashOperator. Это странно, потому...

Ниже мой Ansible код, который пытается установить Airflow 1.10.0. sudo journalctl -u...

У меня есть CSV-файл в облачном хранилище Google.Я использую Google Cloud Composer для запуска...