Začněte nyníZačněte zdarma

Něco s proměnnými nesedí

Šéf tě požádal, abys prošetřil/a problém s tím, že se negeneruje prodejní zpráva. Nedávno jsi implementoval/a proměnné v jednom ze svých DAGů (process_sales), který zpracovává různá prodejní data a zapisuje zprávu, na kterou se šéf ptá. Při prohlížení logů zjistíš, že soubor se nezapisuje na zamýšlené místo, ale na výchozí.

Úloha, která zprávu zpracovává, vypadá takto:

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

Soubor by měl být uložen jako /data/sales/sales_report.pdf.

Zkus spustit příkaz airflow dags test process_sales a prohlédni si výstup logu.

Která z následujících možností popisuje příčinu chyby a jak ji opravit?

Toto cvičení je součástí kurzu

Úvod do Apache Airflow v Pythonu

Zobrazit kurz

Interaktivní praktické cvičení

Proměňte teorii v praxi s jedním z našich interaktivních cvičení

Začít cvičení