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

Какова причина ошибки и как её исправить?

Мониторинг, оповещения и обратные вызовы

Create Your Free Account