XCom を使ったデータの受け渡し

ETL ワークフローを更新し、XCom を使って情報をより簡単に管理できるようにしています。そのために、Dag 内のタスク間の依存関係を更新する必要があります。

以下のように使用できる 4 つのタスクがすでに定義されています。

extract() - order_data を返します
transform(order_data) - 集計データを返します
load(summary_data) - XCom 情報を返しません
send_report() - 通知を処理する非 XCom タスクです

extract() と load() の間に transform タスクを挿入して、チェーンを完成させましょう。
結果を etl_result という名前の変数に代入しましょう。
etl_result 変数の後に send_report が実行されるよう設定しましょう。