This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 2821393915d Fix XCom ``include_prior_dates`` API versioning coverage
(#54810)
2821393915d is described below
commit 2821393915ddec40b074ebf437014e3f773093c1
Author: Kaxil Naik <[email protected]>
AuthorDate: Fri Aug 22 17:10:53 2025 +0100
Fix XCom ``include_prior_dates`` API versioning coverage (#54810)
Extend `AddIncludePriorDatesToGetXComSlice` version change to include
`GetXcomFilterParams` in addition to `GetXComSliceFilterParams`.
This ensures that the include_prior_dates field is properly handled
in API version migrations for both XCom endpoints:
- GET /xcoms/{dag_id}/{run_id}/{task_id}/{key} (single XCom)
- GET /xcoms/{dag_id}/{run_id}/{task_id}/{key}/slice (XCom slice)
This was missed in https://github.com/apache/airflow/pull/53809
---
.../src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py
b/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py
index ec66915e4d9..ccac0b94542 100644
--- a/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py
+++ b/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py
@@ -20,7 +20,7 @@ from __future__ import annotations
from cadwyn import ResponseInfo, VersionChange,
convert_response_to_previous_version_for, endpoint, schema
from airflow.api_fastapi.execution_api.datamodels.taskinstance import DagRun,
TIRunContext
-from airflow.api_fastapi.execution_api.routes.xcoms import
GetXComSliceFilterParams
+from airflow.api_fastapi.execution_api.routes.xcoms import
GetXcomFilterParams, GetXComSliceFilterParams
class AddDagRunStateFieldAndPreviousEndpoint(VersionChange):
@@ -41,10 +41,11 @@ class AddDagRunStateFieldAndPreviousEndpoint(VersionChange):
class AddIncludePriorDatesToGetXComSlice(VersionChange):
- """Add the `include_prior_dates` field to GetXComSliceFilterParams."""
+ """Add the `include_prior_dates` field to GetXComSliceFilterParams and
GetXcomFilterParams."""
description = __doc__
instructions_to_migrate_to_previous_version = (
schema(GetXComSliceFilterParams).field("include_prior_dates").didnt_exist,
+ schema(GetXcomFilterParams).field("include_prior_dates").didnt_exist,
)
