Неверные переменные
Ваш руководитель просит разобраться с проблемой: отчёт по продажам не формируется. Вы недавно добавили переменные в один из ваших DAG-ов (process_sales), который обрабатывает данные о продажах и генерирует нужный отчёт. Просматривая логи, вы замечаете, что файл записывается не в нужное место, а в директорию по умолчанию.
Задача, отвечающая за обработку отчёта, выглядит следующим образом:
@task()
def parse_file():
output_path = Variable.get("Output_Path", default="/home")
output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
save_file("{output_path}/{output_fn}")
Файл должен сохраняться по пути /data/sales/sales_report.pdf.
Запустите команду airflow dags test process_sales, чтобы просмотреть вывод логов.
Какова причина ошибки и как её исправить?
Это упражнение является частью курса
Введение в Apache Airflow на Python
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение