Я использую Airflow 1.10.2. И я пытаюсь определить пользовательский модуль, который будет содержать...

У меня есть DAG с воздушным потоком с 8k задач.Когда я ограничиваю количество задач до 1000, на...

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

Я надеюсь, что кто-то сможет прояснить связь между TensorFlow и его зависимостями (Beam, AirFlow,...

Впервые до BigQuery. В таблице inventory гранулярность равна depot_id и product_id, а в таблице...

Мы используем Google Composer (управляемый сервис Airflow) с airflow v1.10 и Python 3.6.8. Для...

В потоке воздуха диаграмма «Ганта» предлагает довольно хороший взгляд на выполнение запущенных...

Я пытаюсь подключить мой PythonOperator и поместить его в плагины $ AIRFLOW_HOME /, как показано...

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

Я хочу запустить ноутбук JuPyter из док-контейнера, который построен из образа следующим образом:...

У меня следующая структура: И я пытаюсь импортировать скрипт в некоторые файлы inbound_layer,...

У меня на компьютере Mac установлены python2.7 и 3.7.Я установил Python3 по умолчанию в файле

AirLag ETL dag имеет ошибку каждый день Наша установка воздушного потока использует CeleryExecutor

Я работаю над проектом, в котором нам нужно перенести приложение aws в облако Google. Я работаю над...

Я пытаюсь настроить Airflow за nginx, используя приведенные здесь инструкции. файл airflow.cfg...

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

Я на некоторое время застрял с этой проблемой. Я следовал шагам и успешно справлялся с заданиями из...

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

У нас есть много DAG, работающих на Airflow. Когда что-то не получается, мы хотим получить...

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

Я использую Airflow DAG с помощью Google Cloud Composer , который имеет следующее определение: with...

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

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

Что я хочу сделать: - сравнить отсутствующий идентификатор из MySQL и BigQuery - получить все...

У меня запланирован запуск DAG на 10AM каждый понедельник. Вот мое определение dag DAG = models