Что произойдет, если один и тот же dag будет запущен одновременно (или так, что время выполнения...

У меня есть рабочий процесс, в котором у меня есть два параллельных процесса (sentinel_run и...

У меня есть dag, где я использую список нижеприведенных операторов TriggerDagrunoperator-для...

У меня есть 2 рабочих потока воздуха, каждый на машине. На машине A выполняется задача датчика...

Кто-нибудь, скажите, пожалуйста, является ли DAG в потоке воздуха просто графиком (например,...

Я использую воздушный поток Apache, и всякий раз, когда я запускаю команду aws, вывод не...

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

Работа с потоком воздуха. Я пробую простую работу с DAG. Я написал пользовательские операторы и...

При использовании TriggerDagRunOperator для запуска другого DAG, он просто дает общее имя, например...

Можно ли заранее определить переменные, соединения и т. Д. В файле, чтобы они загружались при...

Я создаю процесс передачи информации из BigQuery в облачное хранилище через Airflow. Я использую...

Я пытаюсь установить поток воздуха в Mac OS. У меня установлен Python 3.7.3. Я сделал следующий...

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

У меня есть файл, который определяет объект DAG: dags / my_dag.py from airflow import DAG from...

Согласно https://airflow.apache.org/api.html я могу вызвать DAG Airflow следующим образом: curl -X...

Мне нужно выполнить ту же задачу с воздушным потоком в 12-й день месяца и за 2 дня до последнего...

Я хочу очистить задачи в DAG B, когда DAG A завершит выполнение. И A, и B являются запланированными...

Я пытался использовать примеры DAG с воздушным потоком для запуска target dag с контроллера dag ....

Я использую таблицу управления стабильным / воздушным потоком, в соответствии с файлом readme, мне...

Я получаю эту ошибку 'Сломанный DAG: [/usr/local/airflow/dags/reg_controller_new.py] объект типа'...