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

У нас есть 32 V-CPU с 28 ГБ оперативной памяти с Local Executor, но воздушный поток по-прежнему...

Каков наилучший способ выполнить задачу (A) 3 раза подряд ?: Это задача A -> задача A -> задача A...

Ниже приведена команда, которую я пытаюсь выполнить. Переданные ей параметры должны быть переданы в...

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

Я обновил свой кластер воздушного потока с 1.7.1.3 до 1.10.1.После обновления главная страница UI...

Я получаю эту ошибку при попытке использовать Airflow для get_records (). pymssql.OperationalError:...

Как мне установить переменную для использования во время определенного dag_run.Я знаю о настройке...

благодаря моим недавним исследованиям я понял, что schedule_interval для воздушного потока имеет...

У меня установлена ​​Airflow 1.10.2 с python 3.5.6. Метаданные лежат в базе данных Mysql с...

У меня есть вопрос по изменению внутреннего соединения с SQLite на SQL Server.После ввода...

Поскольку мы обновили поток воздуха с v1.8.1 до v1.10.1, команда ssh, которая выполняется...

edit: Это будет работать, я определил ex_func_airflow (var_1 = i), который вызывал проблему Я хотел...

У меня есть 3 прогона DAG: DAGR 1 выполнено в 2019-02-13 16: 00: 00 DAGR 2 выполнено в 2019-02-13...

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

Я обновил версию воздушного потока с 1.7.3 до 1.10.1.После обновления планировщика, веб-сервера и...

Я новичок в xcom функции Airflow.я попробовал это с PythonOperator, и он работал нормально (то есть...

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

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

Я хочу запустить скрипт Python в потоке воздуха.Чтобы добиться того же, я запускаю скрипт,...

Мы используем Airflow за балансировщиком нагрузки AWS.Тайм-аут балансировщика нагрузки составляет...

У меня есть DAG, который начинается в 7:30 вечера каждый день.Необходимо обработать файлы,...

Я выполняю команду airflow trigger_dag cng-hello_world на сервере воздушного потока, и это привело...

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

Мне было интересно, есть ли ограничение размера памяти для XCOM в воздушного потока ?