Biến chưa chuẩn lắm

Sếp yêu cầu bạn kiểm tra một lỗi khiến báo cáo doanh số không được tạo. Bạn vừa triển khai các biến trong một Dag (process_sales) xử lý dữ liệu bán hàng và ghi ra báo cáo mà sếp đang hỏi. Khi xem log, bạn nhận ra tệp không được ghi vào vị trí mong muốn mà lại ghi vào vị trí mặc định.

Tác vụ xử lý báo cáo thực hiện như sau:

@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}")

Tệp cần được lưu là /data/sales/sales_report.pdf.

Hãy thử chạy lệnh airflow dags test process_sales để xem đầu ra log.

Trong các phương án sau, đâu là nguyên nhân gây lỗi và bạn sẽ khắc phục thế nào?