Airflow — Xcom Example

push = PythonOperator(task_id='push_task', python_callable=push_func) pull = PythonOperator(task_id='pull_task', python_callable=pull_func)

def pull_func(ti): value = ti.xcom_pull(task_ids='push_task', key='result') print(value) airflow xcom example

Title: Mastering Data Sharing in Airflow: XComs Explained with a Real Example push = PythonOperator(task_id='push_task'

def auto_push(): return "auto_xcom" # automatically in XCom airflow xcom example