Airflow Xcom Example _best_ -
One of the most common questions when building DAGs is: π "How do I pass data from one task to another?"
push = PythonOperator(task_id='push_task', python_callable=push_func) pull = PythonOperator(task_id='pull_task', python_callable=pull_func) airflow xcom example
def auto_push(): return "auto_xcom" # automatically in XCom One of the most common questions when building