# Define the DAG with DAG( 'xcom_example_dag', default_args=default_args, schedule_interval='@daily', catchup=False, ) as dag:

# Push context['ti'].xcom_push(key='user_id', value=123)

t2 = PythonOperator( task_id='process_data', python_callable=process_data, provide_context=True, )

In earlier versions of Airflow, you explicitly use the task instance ( ti ) to manage XComs.

extract >> process

Airflow Xcom Example Free [OFFICIAL]

# Define the DAG with DAG( 'xcom_example_dag', default_args=default_args, schedule_interval='@daily', catchup=False, ) as dag:

# Push context['ti'].xcom_push(key='user_id', value=123) airflow xcom example

t2 = PythonOperator( task_id='process_data', python_callable=process_data, provide_context=True, ) ) as dag: # Push context['ti'].xcom_push(key='user_id'

In earlier versions of Airflow, you explicitly use the task instance ( ti ) to manage XComs. value=123) t2 = PythonOperator( task_id='process_data'

extract >> process