Jinja を使った記述

Airflow を使い慣れてきたところで、さまざまな通知コールバックを追加しましたが、受信トレイに届くメッセージがいつも同じ内容で困っています。件名が毎回同じでは、目的のメッセージを見つけるのが大変です。Airflow の Jinja サポートについて調べたところ、件名に識別情報を追加して、DAG が実行されるたびにその日付を含むレポートを送れることがわかりました。まずは sales_update DAG を更新して、正常完了時にテンプレート化された件名のメールを受け取れるようにしましょう。

必要な Airflow のインポートはすでに用意されており、タスク pull_sales_data と generate_sales_report も定義済みです。