Повторное использование переменной кромки/поддага в DAG воздушного потока

#python #airflow Вопрос: Итак, я менял DAG своего рабочего ETL, когда обнаружил что-то подобное. # (...) def build_spark_task(**kwargs) -> SparkTaskConfig: spark_task = SparkTaskConfig(...) # (...) return spark_task def get_spark_k8s_tasks_tuple(**kwargs) ->…