1. Обучение
    2. /
  2. Курса
    3. /
  3. Introduction to Apache Airflow in Python
Connected

упражнение

Passing data with XCom

You're in the process of updating an ETL workflow to use an XCom to more easily keep track of information. As such, you need to update the dependencies between the tasks in your Dag.

You have four tasks defined already that are usable as follows:

  • extract() - Returns order_data
  • transform(order_data) - Returns summarized data
  • load(summary_data) - Does not return XCom information
  • send_report() - A non-XCom task that handles notifications

Инструкции

100 XP
  • Insert the transform task between extract() and load() to complete the chain.
  • Assign the result to a variable called etl_result.
  • Set send_report to run after the etl_result variable.