Я настроил несколько dags, которые в конечном итоге заканчиваются командой spark-submit для искрового кластера. Я использую кластерный режим, если это имеет значение. В любом случае, мой код работает, но я понял, что если задание искры потерпит...

Я борюсь со странной проблемой, которую не могу понять. У меня есть базовая DAG, которая не делает ничего особенного. Он просто использует оператор bash для запуска скрипта Python. У меня запланирован запуск этой DAG каждый понедельник. Когда я...

У нас есть конвейер непрерывной интеграции, который автоматически развертывает наши DAG Airflow на сервере Airflow. При развертывании новой версии группы обеспечения доступности баз данных ее состояние по умолчанию ВЫКЛ . Мы хотели бы включить его...