@task def load(transformed: dict): print(f"Saving: transformed['result']") # no need to pull — Airflow passes XCom automatically
Whether you are using PostgreSQL, MySQL, or SQLite, this architectural design introduces major bottlenecks if abused: airflow xcom exclusive
xcom_objectstorage_threshold : The size threshold for switching backends. 5. Troubleshooting XComs in the UI airflow xcom exclusive