Airflow Xcom Exclusive ((link)) Instant

When you pull without specifying a task_id , you get the latest XCom from any task. To enforce exclusivity, always specify the exact source task.

Apache Airflow’s XComs (short for “cross-communications”) are a core mechanism for passing small pieces of data between tasks. In Airflow 2.8+ a newer XCom type—XComExclusive—was introduced (via community plugins and evolving patterns) to provide a way to ensure an XCom value is consumed by at most one downstream consumer. This post explains the concept, when to use it, how to implement an exclusive-consume pattern, and practical examples. airflow xcom exclusive

# Pushing XCom (implicitly via return) def push_task(**context): return "some_value" When you pull without specifying a task_id ,

To keep your pipelines efficient, follow these core principles: Pass data between tasks | Astronomer Documentation when to use it