Implement a dedicated maintenance DAG that safely purges historical XCom records using a standard SQL execution or the DbApiHook .
To achieve the benefits of XCom exclusive—efficient, lightweight, and maintainable data sharing—follow these guidelines: airflow xcom exclusive
You can manually call the xcom_push method from the task instance. Implement a dedicated maintenance DAG that safely purges
Never use XComs to pass large CSV files, dataframes, images, or massive query outputs. Use them only for tracking IDs, row counts, API tokens, and operational paths. 2. Serialization Failures and operational paths. 2. Serialization Failures