Airflow Xcom Example __exclusive__ ❲1080p - HD❳

The answer:

extract = PythonOperator( task_id='extract_order_task', python_callable=extract_order ) 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') value=123) user = context['ti'].xcom_pull(task_ids='task_a'

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

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