Я новичок в воздушном потоке, и в настоящее время я пытаюсь передавать информацию между своими операторами SimpleHttpOperators. Отсюда извлекаются данные: request_city_information = SimpleHttpOperator( http_conn_id='overpass',...

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

Я использую Airflow 2.0. Я пытаюсь подключиться к красному смещению, используя контейнер докеров на Mac. Вот мой dag.py: from airflow import DAG from datetime import datetime,timedelta from airflow.operators.bash import BashOperator from...