Airflow Xcom Exclusive

Scenario:

from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash_operator import BashOperator airflow xcom exclusive

This is distinct from passing data between functions in a standard Python script. In Airflow, tasks often run on different machines (workers) at different times, so standard memory variables cannot be shared. XCom bridges this gap. Scenario: from datetime import datetime

: Stores a value in the Airflow metadata database. Many operators (and any @task function) automatically push their return value to a special key called return_value by default. airflow xcom exclusive