Airflow Xcom Example Today
3/4 ⚠️ Warning: XCom is NOT for large data (no CSVs, no models). Keep it under 48KB. Use S3/GCS for big files.
XComs allow tasks to exchange small pieces of data (e.g., IDs, filenames, metadata). Think of them as a shared key-value store across your DAG run. airflow xcom example
Title: Mastering Data Sharing in Airflow: XComs Explained with a Real Example 3/4 ⚠️ Warning: XCom is NOT for large
def pull_func(ti): value = ti.xcom_pull(task_ids='push_task', key='result') print(value) python_callable=extract_order ) extract >
extract = PythonOperator( task_id='extract_order_task', python_callable=extract_order )
extract >> process
