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

У меня относительно простой DAG, для демонстрационных целей: generate_permutations >>...

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

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

Я пытался установить воздушный поток на iMac airflow initdb Я получил эту ошибку Traceback (most...

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

Привет. Я случайно развернул группу доступности базы данных с датой Start_date год назад с...

У меня есть сценарий для передачи имен файлов обработки между группами DAG, которые используются...

Я установил airflow 1.10 и могу без проблем запустить веб-сервер airflow, но когда я запускаю...

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

У меня есть простой пример, показывающий DAG с двумя уровнями.При запуске этот даг не выполняется,...

У меня есть Apache Airflow DAG с десятками тысяч задач, и после запуска, скажем, несколько из них...

Я добавил новую группу обеспечения доступности баз данных в свой ~/airflow/dags, и это требует...

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

Мы используем более 150 мешков в нашей производственной среде и часто сталкиваемся с проблемами при...

Я создал группу обеспечения доступности баз данных следующим образом: args = { 'owner':...

Как работает task_ids, если указано несколько задач? В этом конкретном примере кода я ожидал...

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

В Airflow, на чем основан успех SubDagOperator?Из документов «Поток воздуха»: marking success on a...

Мы пытаемся развернуть сжатые пакеты Airflow из Nexus вместе с файлами конфигурации, которые...

Я хочу, чтобы задача не выполнялась после 12 часов ее запуска, я установил execution_timeout на 12...

При сбое узлов в моем dag я хочу видеть журналы, но страница просто продолжает отображать (символ),...

Это мой код: EXEC_TIMESTAMP = "{{ execution_date.strftime('%Y-%m-%d %H:%M') }}"...

Данные публикуются каждое утро понедельника через FTP-сервер.В каталоге каждой недели есть новый...

Apache Airflow 1.10 + представила встроенную поддержку DST-осведомленных часовых поясов . Это...