Airflow Xcom Example __exclusive__ < 95% Ultimate >

The answer:

from airflow import DAG from airflow.operators.python import PythonOperator from datetime import datetime airflow xcom example

# Task 3: Pull Automatic XCom using Jinja Templating # Note: BashOperator supports Jinja templating in bash_command t3 = BashOperator( task_id='log_result', bash_command='echo " ti.xcom_pull(task_ids="process_data") "', ) The answer: from airflow import DAG from airflow

from airflow import DAG from airflow.operators.python import PythonOperator from airflow.operators.bash import BashOperator from datetime import datetime, timedelta import random timedelta import random Happy Orchestrating!

Happy Orchestrating!