Я хочу запустить функцию python в двух ситуациях Когда Даг бежит, значит, когда кто-то запускает...

Я получаю сообщение об ошибке при выполнении задачи Airflow при использовании EmrAddStepsOperator....

Я относительно новичок в области Data Engineering и сталкиваюсь с довольно специфическим...

Я пытаюсь экспортировать простой запрос mysql в файл json (но это может быть и csv), но в журнале...

Я пытаюсь установить библиотеку spacy в PythonVirtualenvOperator.В то время как другие установки...

Я внес небольшое изменение в существующий рабочий процесс, и он нарушил воздушный поток.Вот код:...

Я создал очень простой DAG для выполнения файла Python с использованием PythonOperator. Я использую...

У меня есть dag, который запрашивает базу данных postgress, и я использую postgresOperator Однако...

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

Я установил экземпляр Apache Airflow без дальнейшей настройки (Sequential Executor и SQLLiteDB) на...

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

Я пытаюсь импортировать модуль из двух каталогов выше каталога / dags. Моя структура папок выглядит...

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

Я пытаюсь добавить jaydebeapi в Airflow (размещенный в Google Cloud Composer) с помощью функции...

Может кто-нибудь подсказать, как я могу передать dag-context в качестве аргумента в методе...

В настоящее время я пытаюсь написать метку для копирования файлов из одного местоположения S3 в...

У нас есть 2 разных узла, на которых выполняются разные пакеты Airflow. У нас есть controller_dag...

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

Я использую Airflow с kubernetes executor и KubernetesPodOperator. У меня есть две работы: A:...

Иногда без видимой причины мы получаем сообщение об ошибке «airflow.exceptions

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

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

Моя настройка Airflow в настоящее время состоит из - Airflow 1.10.1 + MySQL Backend + Celery +...

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

В моих работах по зажиганию с воздушным потоком у меня есть требование передавать статистику работ...