Передавання даних за допомогою XCom

Ви оновлюєте ETL‑робочий процес, щоб використовувати XCom і зручніше відстежувати інформацію. Тому вам потрібно оновити залежності між завданнями у вашому Dag.

У вас уже визначено чотири завдання, які використовуються так:

extract() — повертає order_data
transform(order_data) — повертає підсумовані дані
load(summary_data) — не повертає інформації XCom
send_report() — завдання без XCom, що відповідає за сповіщення

Вставте завдання transform між extract() і load(), щоб завершити ланцюжок.
Присвойте результат змінній etl_result.
Налаштуйте send_report на запуск після змінної etl_result.