Airflow Xcom Example Best 95%

3/4 ⚠️ Warning: XCom is NOT for large data (no CSVs, no models). Keep it under 48KB. Use S3/GCS for big files.

extract >> process

process = PythonOperator( task_id='process_order_task', python_callable=process_order ) airflow xcom example

def process_order(**context): # Pull from XCom order_id = context['task_instance'].xcom_pull( task_ids='extract_order_task', key='order_id' ) print(f"Processing order: {order_id}")

# Push context['ti'].xcom_push(key='user_id', value=123) user = context['ti'].xcom_pull(task_ids='task_a', key='user_id') 3/4 ⚠️ Warning: XCom is NOT for large

extract = PythonOperator( task_id='extract_order_task', python_callable=extract_order )

The answer:

from airflow.operators.python import PythonOperator def push_func(ti): ti.xcom_push(key='result', value='hello_xcom')