Coverage for /home/airflow/.local/lib/python3.12/site-packages/airflow/api_fastapi/core_api/datamodels/ui/gantt.py: 100%
19 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 datetime import datetime
22from airflow.api_fastapi.core_api.base import BaseModel
23from airflow.utils.state import TaskInstanceState
26class GanttTaskInstance(BaseModel):
27 """Task instance data for Gantt chart."""
29 task_id: str
30 task_display_name: str
31 try_number: int
32 state: TaskInstanceState | None
33 scheduled_dttm: datetime | None
34 queued_dttm: datetime | None
35 start_date: datetime | None
36 end_date: datetime | None
37 is_group: bool = False
38 is_mapped: bool = False
41class GanttResponse(BaseModel):
42 """Response for Gantt chart endpoint."""
44 dag_id: str
45 run_id: str
46 task_instances: list[GanttTaskInstance]