Я использую Apache-airflow2 .Мои дагы до сих пор работали на LocalExecutor без сбоев.Теперь я хочу...

Я настраиваю свою DAG в Airflow (GC Composer) и пытаюсь использовать шаблоны Jinja2 в моем...

Несколько операторов позволяют извлекать данные, но мне так и не удалось использовать результаты....

Мой оператор воздушного потока внезапно получает ошибку ModuleNotFoundError: No module named...

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

Я пытаюсь установить Airflow (1.10.0), используя Ansible после перехода по ссылке ниже....

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

Я пытаюсь прочитать pyspark DataFrame из Google Cloud Storage, но постоянно получаю сообщение об...

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

У меня DAG, где max_active_runs установлено на 2, но теперь я хочу запускать засыпки для 20-ти...

Я не могу создать соединение с SQL Server в Airflow. Это код, который я использую: t2 =...

Я использую apache-airflow == 1.10.0 Я получаю ошибки, которые выглядят следующим образом:...

Для начала я пытаюсь обновить версию 1.9 до 1.10, поэтому в моей настройке содержатся два...

Я тестирую поток воздуха, но у меня есть одна проблема: окружение Сервер: поток воздуха 1.10,...

Я использую Gcloud Composer в качестве своего воздушного потока.Когда я пытаюсь использовать Jinja...

Я запускаю команду bash в Airflow, включив несколько print() на нескольких этапах, чтобы...

Я вызываю задачу, которая запускает команду python3.Я поместил оператор main is called в первую...

В Airflow - я пытаюсь зациклить оператора.(BigQueryOperator).Группа обеспечения доступности баз...

Как мы получаем run_id в потоке воздуха, как получить метку времени (ts)?

Я хочу создать рабочий процесс, который берет файлы из s3 и сохраняет данные в mongodb, поэтому я...

Я пытаюсь попробовать Airflow в первый раз и пытаюсь подключить его к локальной базе данных SQLite

Когда я запускаю образ докера, используя KubernetesPodOperator в версии Airflow 1.10 Как только...

Я предоставил правильный конфиг для потока воздуха, проверил rabbitmq и работает через sudo service...

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

В соответствии с кодом, задача versionator и fs_task должны быть после задачи register. Однако в...