Подключение классического оператора к задаче TaskFlow
В вашем пайплайне есть BashOperator, который получает текущую дату. Коллега написал функцию с декоратором @task для записи этой метки времени в журнал, однако два компонента пока не связаны между собой.
Вам нужно использовать правильный атрибут классического оператора, чтобы передать его результат в функцию TaskFlow.
Это упражнение является частью курса
Построение пайплайнов данных с Airflow
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение