Airflow Xcom Example Direct

One of the most common questions when building DAGs is: 👉 "How do I pass data from one task to another?"

Use return as a shortcut – return value auto-pushes to return_value key. airflow xcom example

# Push context['ti'].xcom_push(key='user_id', value=123) user = context['ti'].xcom_pull(task_ids='task_a', key='user_id') One of the most common questions when building

Title: Mastering Data Sharing in Airflow: XComs Explained with a Real Example value=123) user = context['ti'].xcom_pull(task_ids='task_a'