From aa60109eb2436021d80f1e76ec84e31e08afe453 Mon Sep 17 00:00:00 2001 From: Kaxil Naik Date: Fri, 22 Aug 2025 02:08:40 +0100 Subject: [PATCH] Fix XCom ``include_prior_dates`` API versioning coverage 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 --- .../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 ec66915e4d908..ccac0b945422a 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 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 @@ def remove_state_from_dag_run(response: ResponseInfo) -> None: # type: ignore[m 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, )