У меня есть DAG и у меня есть 3 задачи.Я не хотел бы отображать 2-е задание (middle_name) в прогоне...
Я использую pyspark spark 2.4.4 и Pycharm Python: 2.7 Пожалуйста, помогите мне, как мне настроить...
У меня есть группа доступности базы данных, где последним заданием является EmailOperator для...
Я хотел бы иметь знак, в котором, если в какой-либо задаче возникает ошибка, он должен...
В настоящее время я запускаю Airflow через Ubuntu WSL на моем ПК, который работает отлично.Однако я...
У меня есть процесс ETL, который в настоящее время переносит данные из удаленной БД в HDFS, а затем...
Я пытаюсь запланировать запуск dag каждые x секунд.Я указываю время начала как прошедшую дату с...
Я пытаюсь заставить Airflow ExternalTaskSensor работать, но до сих пор не удалось его завершить, он...
Я исследую, какие задания по обработке данных занимают больше времени, чем их использование в...
Я очень новичок в Airflow, и у меня есть два подзаголовка, т.е. SUBDAG_A и SUBDAG_B. SUBDAG_A...
С https://airflow.apache.org/scheduler.html: Обратите внимание, что если вы запустите группу...
Я хотел бы добавить проверку / тест для операторов воздушного потока Kubernetes , которые я...
В конфигурационном файле Yaml упоминается: sql: '{{ti.xcom_pull (task_ids = "before_task", key =...
У меня есть DAG с воздушным потоком, у которого BranchPythonOperator вызывает 1 из 4...
Кто-нибудь когда-нибудь получал это предупреждение в журналах воздушного потока? sqlalchemy /...
Я использую Airflow (контейнер Docker) для запуска сценария R.Я получаю следующую ошибку....
Кто-нибудь написал или знает местонахождение оператора воздушного потока для Alteryx?Попытка...
Почему команда trigger_dag в cli не запускается из сбойной задачи после перезапуска? Я использую...
У меня есть знак потока воздуха, который использует следующий шаблон дзиндзя: "{{...
У нас есть DAG, которая получает некоторые данные с рекламной платформы.Эти объявления организованы...
Мы периодически создаем новые группы обеспечения доступности баз данных, которые, в свою очередь,...
Я использую Hadoop и Spark в многоузловой среде. Я установил Airflow для автоматизации нескольких...
Я создал новый DAG, используя следующий код.Он вызывает скрипт Python. Код: from __future__ import...
Я пытаюсь запустить определенную дату в прошлом, которая находится за пределами временной шкалы...
Я должен обновлять (повторно вводить и сохранять) свой пароль SSH-соединения каждый раз, когда я...