airflow

3зной

2ответ

У нас есть несколько приложений, и мы хотим начать использовать воздушный поток. Из документации кажется, что единственный способ запустить DAG - над командной строкой. Это правда? Например, у нас раб

4зной

2ответ

Возможно установить различный исполнитель для каждой DAG воздушного потока?

Я ищу, чтобы добавить еще одну DAG на существующий сервер Airflow. В настоящее время сервер использует LocalExecutor, но мне может потребоваться, чтобы моя DAG использовала CeleryExecutor. Похоже, что

0зной

1ответ

Когда обновлять исполнителя Airflow от LocalExecutor до CeleryExecutor?

В настоящее время я использую несколько DAG для Airflow, используя LocalExecutor, и он работает нормально. У моего сервера много ресурсов. Я собираюсь добавить новую DAG для более крупного проекта, и

1зной

1ответ

Воздушный поток не задерживает последний прогон

По какой-то причине Airflow, похоже, не запускает последний прогон для дага с недельным интервалом расписания. Текущая дата: $ date $ Tue Aug 9 17:09:55 UTC 2016 DAG: from datetime import datetime

1зной

2ответ

Почему запуск `airflow clear` с использованием опции -t вызывает ошибку потока?

Я построил DAG Airflow с настройками по умолчанию в качестве учебника. Когда я запускаю DAG, некоторые задачи не выполнялись. При попытке удалить неудачные задачи, используя airflow clear my_dag -s 20

14зной

2ответ

Хотя воздушный поток initdb, ImportError: не может импортировать имя HiveOperator

Я недавно установил airflow для своих рабочих процессов. Создавая свой проект, я выполнил следующую команду: airflow initdb , возвращающий следующее сообщение об ошибке: [2016-08-15 11:17:00,314] {_

2зной

1ответ

Доступ к дамскому идентификатору AirFlow в подзадачи

У меня есть DAG с тремя задачами bash, которые планируется запустить каждый день. Я хотел бы получить уникальный идентификатор экземпляра dag (может быть PID) во всех сценариях bash. Есть ли способ сд