Airflow Xcom Exclusive

, which allows a task to request specific values from one or more previous tasks. Explicit Storage: Tasks must explicitly "push" data to the Airflow metadata database

Tasks can manually interact with the XCom registry using context['task_instance'].xcom_push() and xcom_pull() . Key Constraints of Standard XComs airflow xcom exclusive

: While primarily used within one DAG, xcom_pull can be configured with a different dag_id to retrieve values from an entirely separate workflow, provided you have the correct execution date or use include_prior_dates=True . Critical Limitations XComs — Airflow 3.2.1 Documentation , which allows a task to request specific

@task def consumer_1(data): # data is automatically pulled only to this task print(data) airflow xcom exclusive