Возврат данных из функции TaskFlow
Ваша команда хранит конфигурацию пайплайна в отдельной задаче, чтобы её можно было повторно использовать в последующих шагах. Централизованное хранение конфигурации — распространённая практика в продакшене: одна задача определяет настройки, а все остальные читают одни и те же значения вместо того, чтобы прописывать их напрямую. Задача get_config уже возвращает словарь конфигурации, а run_pipeline готова его принять.
Это упражнение является частью курса
Построение пайплайнов данных с Airflow
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение