Coverage for /home/airflow/.local/lib/python3.12/site-packages/airflow/api_fastapi/execution_api/versions/v2025_04_28.py: 100%
6 statements
« prev ^ index » next coverage.py v7.15.2, created at 2026-10-07 14:22 +0000
« prev ^ index » next coverage.py v7.15.2, created at 2026-10-07 14:22 +0000
1# Licensed to the Apache Software Foundation (ASF) under one
2# or more contributor license agreements. See the NOTICE file
3# distributed with this work for additional information
4# regarding copyright ownership. The ASF licenses this file
5# to you under the Apache License, Version 2.0 (the
6# "License"); you may not use this file except in compliance
7# with the License. You may obtain a copy of the License at
8#
9# http://www.apache.org/licenses/LICENSE-2.0
10#
11# Unless required by applicable law or agreed to in writing,
12# software distributed under the License is distributed on an
13# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14# KIND, either express or implied. See the License for the
15# specific language governing permissions and limitations
16# under the License.
18from __future__ import annotations
20from cadwyn import VersionChange, schema
22from airflow.api_fastapi.execution_api.datamodels.taskinstance import (
23 TIDeferredStatePayload,
24 TIRetryStatePayload,
25 TISuccessStatePayload,
26 TITerminalStatePayload,
27)
30class AddRenderedMapIndexField(VersionChange):
31 """Add the `rendered_map_index` field to payload models."""
33 description = __doc__
35 instructions_to_migrate_to_previous_version = (
36 schema(TITerminalStatePayload).field("rendered_map_index").didnt_exist,
37 schema(TISuccessStatePayload).field("rendered_map_index").didnt_exist,
38 schema(TIDeferredStatePayload).field("rendered_map_index").didnt_exist,
39 schema(TIRetryStatePayload).field("rendered_map_index").didnt_exist,
40 )