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

Я получаю предупреждение: WARNING - schedule_interval is used for <Task(BigQueryOperator):...

My Airflow DAG имеет оператора Postgres, который мне хотелось бы знать, на сколько строк это влияет

Я установил соединение с базой данных через переменную среды следующим образом:...

Я пытаюсь создать SimpleHttpOperator. Я впервые попробовал task1 = SimpleHttpOperator(...

Я пытался найти этот ответ, но не смог найти ничего, что имеет смысл для того, что я пытаюсь...

У меня проблемы с получением дополнительных ссылок оператора для рендеринга для Airflow. У нас есть...

Предположим, у меня есть файл dag воздушного потока, который создает график, подобный так ... def...

У меня есть DAG, которая использует ShortCircuitOperator для пропуска последующих задач, которые...

Когда я в первый раз загружаю веб-сервер и планировщик Airflow 25 октября около 17:23 и включаю DAG...

В моей DAG хотел пропустить задачу (oracle_merge_hist_orig), зависящую от флага. Моя логика: когда...

Есть ли способ ежедневно обновлять dag воздушного потока на основе кода определения файла dagfile?...

Как автоматически прекратить прохождение воздушных потоков (в незапланированное время) при первом...

Установлен поток воздуха, и я использую стандартную базу данных sqlite. Обнаружение, что функции Ad...

веб-сервер airflow может работать без проблем. Планировщик воздушного потока может получить...

Вопрос Можно ли настроить типизированную переменную datetime через веб-приложение? Например, если я...

У меня есть график воздушного потока с условной ветвью, определенной как class BranchFlags(Enum):...

Я хочу выполнить запрос улья, используя HiveOperator, и вывод этого запроса должен быть перенесен в...

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

У меня есть задача Airflow, которая запускается youtube-dl и работает нормально. Я запускаю это с...

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

Я установил Airflow с celeryexecutor, имеющим 2 рабочих, 1 планировщик и 1 веб-сервер. Я запускаю...

Я настраиваю Airflow с Google Cloud Storage. Ранее я установил соединение в другой среде и пытаюсь...

Совершенно новичок в Airflow, любопытно, есть ли у кого-нибудь предложения о том, как решить мою...

Я хотел бы запустить dag, срабатывающий в конце другого dag и пропуская некоторый параметр. После...