НачатьНачать бесплатно

Неверные переменные

Ваш руководитель просит разобраться с проблемой: отчёт по продажам не формируется. Вы недавно добавили переменные в один из ваших 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

Посмотреть курс

Практическое интерактивное упражнение

Превратите теорию в практику с помощью одного из наших интерактивных упражнений

Начать упражнение