Моя цель - легко экспортировать события из Airflow в другие системы. Один из вариантов - создать...

Я хочу отправлять данные на сервер в фоновом режиме каждую 1 минуту. Я попытался отправить данные...

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

У меня есть следующий код с использованием планировщика и модуля многопроцессорной обработки: def...

У меня настроен честный планировщик, как указано в документе: conf.set("spark.scheduler

Я только что установил Airflow 1.10 на один сервер , используя sudo -E pip-3.6 install...

We are running airflow version 1.9 in celery executor mode. Our task instances are stuck in retry...

Кто-нибудь сообщил, сколько они смогли увеличить Airflow в своей компании? Я смотрю на реализацию...

Мы экспериментируем с Apache Airflow (версия 1.10rc2, с python 2.7) и разворачиваем его на...

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

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

В Heron я создал экземпляр SchedulerStateManagerAdaptor с именем adaptor, используя IStateManager,...

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

Выполнение конвейерного режима Azkaban приводит к сбою заданий после накопления достаточного...

Я использую Воздушный поток 1.8.0 и у меня есть DAG, как этот: default_args = { 'owner':...

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

DAG A имеет расписание '0 6 * * *'. DAG B имеет расписание '* / 5 * * * *'. Однако группа...

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

Я Расписание выражений с использованием курса или Cron - AWS Lambda . Вопрос: Будет ли rate(0...

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

Я оцениваю Airflow 1.9.0 для наших потребностей распределенной оркестровки (используя...

У меня три задания t1,t2,t3. вывод каждой задачи является следующим вводом задачи, например, t1...

У меня есть нижеприведенные настройки dag для запуска catchup с 2015 года. Для каждой даты...

У меня есть два рабочих и 3 задания. dag = DAG('dummy_for_testing',...

Я использую TYPO3 6.2 и создал собственное расширение с Extbase и Fluid.Я сделал пользовательскую...