Я пытаюсь преобразовать задание искровой отправки, которое настраивалось через файл yaml, в dag воздушного потока и запустить его через воздушный поток. Задание не выполняется, когда я пытаюсь смонтировать…
airflow-operator
Я пытался использовать макросы Airflow, ссылающиеся на переменные по умолчанию и BigQuery. метки для регистрации метаданных запросов, отправленных через Airflow BigQueryOperator. Вот определение оператора: BigQuery_Labels_Test_Task = BigQueryOperator( task_id=»BigQuery_Labels_Test_Task»,…
Я хочу создать родительский DAG с несколькими дочерними DAG, которые вызываются через SubDagOperator. Я могу найти только примеры динамического создания субдагов в задаче SubDagOperator. Однако в этом случае…