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 e5a5a8692cf Update Cadwyn migration dates after 3.0.5 (#54487)
e5a5a8692cf is described below
commit e5a5a8692cfa969313e2739e15d9a6c7bbc1ff1b
Author: Kaxil Naik <[email protected]>
AuthorDate: Thu Aug 14 12:57:01 2025 +0100
Update Cadwyn migration dates after 3.0.5 (#54487)
`AddDagVersionIdField` migration would be part of 3.1 so updating dates
based on that.
The other migrations are part of 3.0.5rc1 already.
---
.../api_fastapi/execution_api/versions/__init__.py | 4 +--
.../execution_api/versions/v2025_08_10.py | 10 +-------
.../versions/{__init__.py => v2025_09_23.py} | 29 +++++++---------------
.../src/airflow/sdk/api/datamodels/_generated.py | 2 +-
4 files changed, 13 insertions(+), 32 deletions(-)
diff --git
a/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
b/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
index 1fe0b9d155f..84d676347ac 100644
--- a/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
+++ b/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
@@ -23,15 +23,15 @@ from airflow.api_fastapi.execution_api.versions.v2025_04_28
import AddRenderedMa
from airflow.api_fastapi.execution_api.versions.v2025_05_20 import
DowngradeUpstreamMapIndexes
from airflow.api_fastapi.execution_api.versions.v2025_08_10 import (
AddDagRunStateFieldAndPreviousEndpoint,
- AddDagVersionIdField,
AddIncludePriorDatesToGetXComSlice,
)
+from airflow.api_fastapi.execution_api.versions.v2025_09_23 import
AddDagVersionIdField
bundle = VersionBundle(
HeadVersion(),
+ Version("2025-09-23", AddDagVersionIdField),
Version(
"2025-08-10",
- AddDagVersionIdField,
AddDagRunStateFieldAndPreviousEndpoint,
AddIncludePriorDatesToGetXComSlice,
),
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 c6c95c7dfdc..ec66915e4d9 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
@@ -19,18 +19,10 @@ 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,
TaskInstance, TIRunContext
+from airflow.api_fastapi.execution_api.datamodels.taskinstance import DagRun,
TIRunContext
from airflow.api_fastapi.execution_api.routes.xcoms import
GetXComSliceFilterParams
-class AddDagVersionIdField(VersionChange):
- """Add the `dag_version_id` field to the TaskInstance model."""
-
- description = __doc__
-
- instructions_to_migrate_to_previous_version =
(schema(TaskInstance).field("dag_version_id").didnt_exist,)
-
-
class AddDagRunStateFieldAndPreviousEndpoint(VersionChange):
"""Add the `state` field to DagRun model and `/dag-runs/{dag_id}/previous`
endpoint."""
diff --git
a/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
b/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_09_23.py
similarity index 51%
copy from
airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
copy to
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_09_23.py
index 1fe0b9d155f..dcea9a6a0e8 100644
--- a/airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py
+++ b/airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_09_23.py
@@ -17,25 +17,14 @@
from __future__ import annotations
-from cadwyn import HeadVersion, Version, VersionBundle
+from cadwyn import VersionChange, schema
-from airflow.api_fastapi.execution_api.versions.v2025_04_28 import
AddRenderedMapIndexField
-from airflow.api_fastapi.execution_api.versions.v2025_05_20 import
DowngradeUpstreamMapIndexes
-from airflow.api_fastapi.execution_api.versions.v2025_08_10 import (
- AddDagRunStateFieldAndPreviousEndpoint,
- AddDagVersionIdField,
- AddIncludePriorDatesToGetXComSlice,
-)
+from airflow.api_fastapi.execution_api.datamodels.taskinstance import
TaskInstance
-bundle = VersionBundle(
- HeadVersion(),
- Version(
- "2025-08-10",
- AddDagVersionIdField,
- AddDagRunStateFieldAndPreviousEndpoint,
- AddIncludePriorDatesToGetXComSlice,
- ),
- Version("2025-05-20", DowngradeUpstreamMapIndexes),
- Version("2025-04-28", AddRenderedMapIndexField),
- Version("2025-04-11"),
-)
+
+class AddDagVersionIdField(VersionChange):
+ """Add the `dag_version_id` field to the TaskInstance model."""
+
+ description = __doc__
+
+ instructions_to_migrate_to_previous_version =
(schema(TaskInstance).field("dag_version_id").didnt_exist,)
diff --git a/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
b/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
index 7c4f73789ef..eeb109d375e 100644
--- a/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
+++ b/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
@@ -27,7 +27,7 @@ from uuid import UUID
from pydantic import AwareDatetime, BaseModel, ConfigDict, Field, JsonValue,
RootModel
-API_VERSION: Final[str] = "2025-08-10"
+API_VERSION: Final[str] = "2025-09-23"
class AssetAliasReferenceAssetEventDagRun(BaseModel):
