Я уже некоторое время оцениваю воздушный поток, и мне действительно нравятся многие функции.Сейчас...

После запуска в течение нескольких дней веб-интерфейс Google Cloud Composer бесконечно возвращает...

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

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

Я выполнил шаги из здесь и успешно запустил блоки в Minikube. Теперь я пытаюсь запустить блоки в...

Как запустить Dag воздушного потока для указанного количества раз? Я пытался использовать...

Я новичок в Airflow и Spark, и я борюсь с SparkSubmitOperator . Наш планировщик воздушного потока и...

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

Я создал среду композитора с помощью интерфейса консоли, а затем установил три переменные с помощью...

У меня есть следующие модули: NAME READY STATUS RESTARTS AGE airflow-database-init-job-ggk95 0/1...

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

Как устранить ошибку: нет модуля с именем pandas, когда один узел (в DAG Airflow) успешно его...

Вопрос Можно ли зафиксировать транзакцию SQL в БД с помощью read_sql ()? Вариант использования и...

Я использую GCP Composer API (Airflow) и мою группу обеспечения доступности баз данных, чтобы...

Работа над некоторыми идеями мониторинга воздушного потока.Когда я выполняю airflow list_tasks...

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

Я использую много операторов Postgres внутри моей Airflow DAG (собирая его с помощью цикла for), и...

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

Я пытаюсь использовать Airflow HdfsSensor в моей DAG для поиска _SUCCESS. DAG: hdfs_sense_open =...

У нас был пользовательский интерфейс Airflow, основанный на этой ссылке , и он работал нормально с...

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

Я пытаюсь установить apache-airflow рекомендуемым способом с pip install apache-airflow.Во время...

Я запускаю Apache Airflow в Kubernetes и сталкиваюсь со странной ошибкой при попытке извлечь файлы...

Airflow 1.10.1 имеет атрибут «logging_level», который, я считаю, связан с уровнем ведения журнала...

Я вижу несоответствие в попытках Airflow или, может быть, я что-то упустил.По сути, у меня retries...