Airflow Xcom Exclusive ◉ (CONFIRMED)
You enable exclusive mode but still store heavy objects in the default DB. Solution: Use CustomXComBackend that serializes large objects to external storage (GCS, S3, Redis) and stores only a URI in the xcom table.
def load(**context): final = context['ti'].xcom_pull(task_ids='transform') print(final) airflow xcom exclusive
In Apache Airflow, (cross-communication) is the primary mechanism for tasks to share small amounts of data. While XComs are widely accessible across a DAG by default, "exclusive" behavior usually refers to strictly scoping data to a specific task instance or preventing cross-DAG leakage. 🚀 Airflow XCom: Core Concepts You enable exclusive mode but still store heavy
XCom rows are uniquely identified by this combination of columns in Airflow database: airflow xcom exclusive