Змінні налаштовані не зовсім правильно
Ваш керівник просить розібратися, чому не генерується звіт про продажі. Ви нещодавно додали змінні в один із ваших 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
Практична інтерактивна вправа
Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ
Почати вправу