変数の設定に問題あり
上司から、売上レポートが生成されていないという問題を調査するよう依頼されました。最近、各種の売上データを処理して上司が求めているレポートを出力する DAG(process_sales)に変数を導入しました。ログを確認したところ、意図した場所ではなく、デフォルトの場所に出力されていることがわかりました。
レポートを処理するタスクは次のとおりです。
@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}")
ファイルの保存先は /data/sales/sales_report.pdf である必要があります。
airflow dags test process_sales コマンドを実行して、ログ出力を確認してみましょう。
エラーの原因と修正方法として正しいものはどれですか?
この演習はコースの一部です
