Airflow Xcom Exclusive ❲2026 Update❳

def push_explicit(**context): context['ti'].xcom_push(key='my_key', value='my_value')

Use ShortCircuitOperator with exclusive mode to stop downstream tasks if a certain key’s value doesn’t meet a threshold: airflow xcom exclusive

def load_data(**kwargs): ti = kwargs['ti'] def push_explicit(**context): context['ti']