Aan de slagBegin gratis

Variabelen kloppen net niet

Je manager vraagt je te onderzoeken waarom een verkooprapport niet wordt gegenereerd. Je hebt onlangs variabelen geïmplementeerd in een van je Dags (process_sales) die allerlei verkoopgegevens verwerkt en het rapport schrijft waar je manager om vraagt. In de logs zie je dat er niet naar de bedoelde locatie wordt geschreven, maar naar de standaardlocatie.

De taak die het rapport verwerkt doet het volgende:

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

Het bestand moet worden opgeslagen als /data/sales/sales_report.pdf.

Probeer het commando airflow dags test process_sales uit te voeren om de logoutput te bekijken.

Wat is de reden voor de fout en hoe los je dit op?

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Bekijk cursus

Interactieve oefening met praktijkervaring

Zet theorie om in actie met een van onze interactieve oefeningen

Begin oefening