Variabile care nu sunt tocmai corecte

Șeful tău îți cere să investighezi o problemă în care un raport de vânzări nu este generat. Ai implementat recent variabile într-unul dintre DAG-urile tale (process_sales), care procesează diverse date de vânzări și generează raportul despre care vorbește șeful tău. Uitându-te la loguri, observi că fișierul nu este scris în locația dorită, ci într-una implicită.

Tasca care procesează raportul face următorul lucru:

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

Fișierul ar trebui salvat la /data/sales/sales_report.pdf.

Încearcă să rulezi comanda airflow dags test process_sales pentru a vedea rezultatul din loguri.

Care dintre variantele de mai jos reprezintă cauza erorii și cum ai rezolva-o?