Я хочу сохранить состояние счетчика между касаниями в датчике длительной работы в режиме...

Я интенсивно искал блоги и документацию по воздушным потокам для отладки возникшей проблемы. Что я...

Как проверить ответ от команды при использовании SSHOperator? t1 =...

Мы все относительно новички здесь, в Airflow, поэтому этот вопрос немного смутил всех нас.В рамках...

Я использую Airflow v1.9.0 с Celery Executor. Я настроил разных работников с разными именами...

Я использую Airflow v1.9 с Celery Executor.У меня 5 рабочих Airflow, работающих на 5 разных машинах

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

У меня есть скрипт pyspark, который отлично работает сейчас, и я хочу планировать эту работу на...

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

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

Как прочитать XCom предыдущего сообщения с помощью SimpleHttpsOperator, а затем принять решение...

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

Я хочу установить определенное время ожидания для моего BashOperator, используя execution_timeout,...

Я пытаюсь запустить BigQueryOperator с некоторым динамическим параметром, основанным на предыдущей...

У меня есть dag, который выполняет 4 задачи, которые все являются операторами bash.Недавно я...

У меня есть dag, в котором выполняется операция dbcleanup, при запуске этого dag на потоке воздуха...

Я использую Google OAuth2 для аутентификации в версии Airflow: 1.10.2. Если я назначу пользователя...

Я использую Airflow версии 1.9.0, и у меня будут сотни Дагов.Есть ли способ упорядочить интерфейс...

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

Я использую оператор (оператор subdag, с taskid "XYZ") в DAG A, и у меня также есть...

Можно ли установить retry_delay на уровне задачи? У меня "global" retry_delay при default_args как...

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

Я могу захватить контекст экземпляра задачи в потоке apache и получить доступ из методов, но мне...

Я пытаюсь создать полноценный даг. Я должен использовать SparkSubmitOperator, но я не знаю все...

Я уже некоторое время использую Apache Airflow, и из-за сценария использования мне нужно переписать...