Может ли задача быть помечена как неудачная из-за ее "on_success_callback" Вариант использования:...
Краткая справка: я настроил Airflow на Kubernetes (на AWS).Я могу запускать группы обеспечения...
Я использую Airflow v1.10.2 и ссылаюсь на экспериментальная документация REST API . Когда я пытаюсь...
Я следил за этим сообщением в блоге , и по этой команде helm upgrade --install airflow airflow/ \...
Я запускаю контейнер для воздушного потока, в котором Мой воздушный поток не может подключиться к...
Я устанавливаю журналы воздушного потока для загрузки в корзину S3. Этот вопрос - моя установка....
Невозможно изменить часовой пояс по умолчанию в airflow.cfg Привет, Я не могу изменить время по...
Я использую Apache Airflow версии 1.8.1. У нас есть два экземпляра GCP - ведущий и рабочий, на...
При создании среды композитора в GCP я получаю эту ошибку: Http error status code: 400 Http error...
Я очень новичок в Airflow и прочитал большую часть его документации. Из документации я понимаю, что...
Простой вопрос: Вместо того, чтобы использовать S3 или GCS, я хотел бы знать, как использовать...
Я пытаюсь запустить поток воздуха в док-контейнере и отправить логи на s3. У меня следующая среда...
У меня есть параллельное выполнение 2 задач ниже в моем DAG В реальном мире это могут быть 15 или...
У меня есть модуль Python, который имеет следующую структуру: my_module/ ... tests/ __init__.py...
Я недавно обновил свой кластер Airflow с 1.7.1.3 до 1.10.2 с mysql в качестве бэкэнда и rabbitmq...
У меня есть скрипт на python, который динамически создает задачу (оператор воздушного потока) и DAG...
Мы перешли на puckel / Airflow-1.10.2, чтобы попытаться устранить низкую производительность,...
Я пытаюсь запустить простой KubernetesPodOperator в моей среде Composer согласно документации,...
Невозможно получить электронную почту при сбое задачи или даже при использовании EmailOperator...
У меня есть панда. Рамка данных df с df.index, которая выдает что-то вроде этого:...
Я только что настроил поток воздуха на локальном, инкапсулирован в док-контейнер. Мне было...
Я использую Google cloud composer и создал среду composer. Среда Composer готова (имеет зеленую...
Я должен сгенерировать даг. Я сохранил файлы схемы таблицы json на GCP bucket . Файлы в корзине GCP...
Я пытаюсь запустить задачу облачной функции Google в группах доступности баз данных и обнаружил,...
Я новичок в Airflow.Я устанавливаю это pip install apache-airflow.Когда я запускаю команду airflow...