Airflow Xcom Example -
push = PythonOperator(task_id='push_task', python_callable=push_func) pull = PythonOperator(task_id='pull_task', python_callable=pull_func)
process = PythonOperator( task_id='process_order_task', python_callable=process_order ) airflow xcom example
from airflow.operators.python import PythonOperator def push_func(ti): ti.xcom_push(key='result', value='hello_xcom') push = PythonOperator(task_id='push_task'
extract = PythonOperator( task_id='extract_order_task', python_callable=extract_order ) python_callable=extract_order ) extract >
extract >> process