Я пытаюсь запустить Apache Airflow, но получаю ошибку с Gunicorn.Моя операционная система OSX High...
У меня есть AIRFLOW DAG со следующей структурой. Все функции, которые начинаются с «check *» - это...
Чтобы уменьшить расходы, связанные с запуском google-cloud-composer, меня интересует возможность...
Мы используем Cloud Composer (Управляемый поток воздуха в GCP) для организации наших задач.Мы...
Последняя версия Airflow 1.10 требует некоторых настроек для регистратора. Я тщательно следовал...
Я настраиваю веб-аутентификацию для веб-сервера Airflow.Я добавил несколько пользователей, следуя...
Я пытаюсь настроить группу обеспечения доступности баз данных, где задача запускается каждую минуту...
Я пытаюсь заставить работать поток воздуха, чтобы лучше организовать процесс etl.Когда я делаю...
Я пытаюсь написать модульные тесты на python для тестирования конвейера Airflow DAG.Я видел менее...
Я хочу использовать динамическое время {{ macros.ds_add(ds, 0) }}, поэтому pandas_gbq.read_gbq не...
Я смутно помню, что по умолчанию значение execute_timeout составляет 15 минут или 30 минут, но я...
Может ли кто-нибудь помочь мне понять столбец «расписание» в веб-интерфейсе airflow. Почему иногда...
Я использую airflow для организации процесса etl и построил следующую задачу: for sql_file in...
Может ли кто-нибудь помочь мне дать несколько советов о том, как мы реализуем Lineage Data в...
Когда я запускаю скрипт, он не выдает ошибку, но не выполняет задачу, которая хранит данные из API...
Я пытаюсь запустить пример в документации Google Cloud Composer и я нахожу проблемы, в основном...
Скажите, что большинство моих групп обеспечения доступности баз данных и задач в AirFlow должны...
В Apache Airflow, возможно ли перехватить исходное сообщение об ошибке, которое вызвала сбойная...
То, чего я пытаюсь достичь, это что-то вроде этого: Запуск DAG из пользовательского интерфейса или...
У меня есть задание, которое назначается каждые несколько минут. Я хочу реализовать логику, когда...
Как какая-то статья, которую я ранее читал.Там сказано, что в новой версии Kubernetes уже есть...
Согласно документации здесь: https://cloud.google.com/composer/docs/release-notes Композитор (GCP's...
Я хочу настроить Dask для распространения DAG в Airflow.Я прочитал https://airflow.apache
Кто-нибудь может дать мне пример передачи некоторых параметров как "runAsNonRoot" при создании...
Я использую airflow для организации некоторых сценариев Python.У меня есть «главный» даг, из...