Я хочу запустить расписание на Airflow (v1.9.0). Моя группа обеспечения доступности баз данных...

Я реализовал оповещения по электронной почте об успехах и неудачах, используя on_success_callback и...

Я устанавливаю airflow с версией Python 3.7.3 и использую команду pip install apache-airflow, но...

Когда у меня есть большое количество задач в группе DAG или SUBDAG, я замечаю, что интерфейс...

Мой пример использования следующий: Task A генерирует dataset с использованием некоторых исходных...

Версия воздушного потока: 1.10.0 Следуя этому руководству Я создал папку sensors и my_sensor.py, я...

Мы установили поток воздуха в среде Linux после создания виртуальной среды. Он был установлен как...

С потоком воздуха 1.10.3 в Ubuntu 14.04 CTS я нашел два запутанных вопроса, любые разъяснения...

Я выполняю 5 задач PythonOperator в моей DAG-системе airflow, и одна из них выполняет работу ETL,...

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

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

У меня DAG, как показано ниже, с dagrun_timeout, установленным на 4 часа.Когда я перехожу к...

Я новичок в Airflow, я хочу скрыть trigger_Dag от веб-интерфейса, чтобы каждый мог использовать cli...

При очистке задачи группы обеспечения доступности баз данных на январь и февраль 2019 года я...

Мой веб-сервер Airflow запущен и работает, так как другие задания выполняются в соответствии с...

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

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

Я создаю Airflow @daily DAG, у него есть восходящая задача get_daily_data BigQueryGetDataOperator,...

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

У меня есть планировщик Airflow и служба веб-сервера, работающие в разных экземплярах. Когда я...

Я пытаюсь установить Airflow в Kubernetes на Amazon ECR.Может кто-нибудь помочь мне с шагами?Также...

Я разрабатываю собственный плагин воздушного потока, который должен отображать (пользовательскую)...

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

Я извлекаю данные из API и помещаю в bigquery.Я хотел бы динамически изменить таблицу bigquery, в...

Есть ли способ указать, что задача может быть запущена только один раз одновременно? Таким образом,...