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
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení