Fix Execution API incompatibilty with addition of consumed_asset_events (#48888)

Author: ashb

airflow-core/src/airflow/api_fastapi/execution_api/versions/__init__.py

@@ -23,9 +23,11 @@
     AddIncludePriorDatesParam,
     RemoveTIRuntimeChecksEndpoint,
 )
+from airflow.api_fastapi.execution_api.versions.v2025_04_10 import AddConsumedAssetEventsField
 
 bundle = VersionBundle(
     HeadVersion(),
+    Version("2025-04-10", AddConsumedAssetEventsField),
     Version("2025-03-26", RemoveTIRuntimeChecksEndpoint, AddIncludePriorDatesParam),
     Version("2025-03-19"),
 )

airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_04_10.py

@@ -0,0 +1,30 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+from __future__ import annotations
+
+from cadwyn import VersionChange, schema
+
+from airflow.api_fastapi.execution_api.datamodels.taskinstance import DagRun
+
+
+class AddConsumedAssetEventsField(VersionChange):
+    """Add the `consumed_asset_events` to DagRun model."""
+
+    description = __doc__
+
+    instructions_to_migrate_to_previous_version = (schema(DagRun).field("consumed_asset_events").didnt_exist,)

task-sdk/src/airflow/sdk/api/datamodels/_generated.py

@@ -27,7 +27,7 @@
 
 from pydantic import AwareDatetime, BaseModel, ConfigDict, Field, JsonValue
 
-API_VERSION: Final[str] = "2025-03-26"
+API_VERSION: Final[str] = "2025-04-10"
 
 
 class AssetAliasReferenceAssetEventDagRun(BaseModel):