В основном я работаю с потоком воздуха и разработал задачу загрузки файла из внешнего источника. t1...

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

Я очень плохо знаком с потоком воздуха и использую функции "xcom_push" и "xcom_pull". У меня есть...

Я пытаюсь найти наиболее общий / эффективный способ передачи переменных из одной задачи...

Так что я боролся с этим часами. Это код моего оператора: task1 = GKEPodOperator(...

Согласно https://airflow.apache.org/api.html я могу вызвать DAG Airflow следующим образом: curl -X...