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, )