apache · ashb · Mar 11, 2025 · Mar 11, 2025
diff --git a/airflow/api_fastapi/core_api/datamodels/dags.py b/airflow/api_fastapi/core_api/datamodels/dags.py
@@ -61,7 +61,6 @@ class DAGResponse(BaseModel):
     is_active: bool
     last_parsed_time: datetime | None
     last_expired: datetime | None
-    default_view: str | None
     fileloc: str
     description: str | None
     timetable_summary: str | None

diff --git a/airflow/api_fastapi/core_api/openapi/v1-generated.yaml b/airflow/api_fastapi/core_api/openapi/v1-generated.yaml
@@ -8227,11 +8227,6 @@ components:
             format: date-time
           - type: 'null'
           title: Last Expired
-        default_view:
-          anyOf:
-          - type: string
-          - type: 'null'
-          title: Default View
         fileloc:
           type: string
           title: Fileloc
@@ -8387,7 +8382,6 @@ components:
       - is_active
       - last_parsed_time
       - last_expired
-      - default_view
       - fileloc
       - description
       - timetable_summary
@@ -8457,11 +8451,6 @@ components:
             format: date-time
           - type: 'null'
           title: Last Expired
-        default_view:
-          anyOf:
-          - type: string
-          - type: 'null'
-          title: Default View
         fileloc:
           type: string
           title: Fileloc
@@ -8544,7 +8533,6 @@ components:
       - is_active
       - last_parsed_time
       - last_expired
-      - default_view
       - fileloc
       - description
       - timetable_summary
@@ -8973,11 +8961,6 @@ components:
             format: date-time
           - type: 'null'
           title: Last Expired
-        default_view:
-          anyOf:
-          - type: string
-          - type: 'null'
-          title: Default View
         fileloc:
           type: string
           title: Fileloc
@@ -9065,7 +9048,6 @@ components:
       - is_active
       - last_parsed_time
       - last_expired
-      - default_view
       - fileloc
       - description
       - timetable_summary

diff --git a/airflow/cli/commands/remote_commands/dag_command.py b/airflow/cli/commands/remote_commands/dag_command.py
@@ -90,7 +90,6 @@ class Meta:
     is_active = auto_field(dump_only=True)
     last_parsed_time = auto_field(dump_only=True)
     last_expired = auto_field(dump_only=True)
-    default_view = auto_field(dump_only=True)
     fileloc = auto_field(dump_only=True)
     file_token = fields.Method("get_token", dump_only=True)
     owners = fields.Method("get_owners", dump_only=True)
@@ -295,7 +294,6 @@ def _get_dagbag_dag_details(dag: DAG) -> dict:
         "is_active": dag.get_is_active(),
         "last_parsed_time": None,
         "last_expired": None,
-        "default_view": dag.default_view,
         "fileloc": dag.fileloc,
         "file_token": None,
         "owners": dag.owner,

diff --git a/airflow/config_templates/config.yml b/airflow/config_templates/config.yml
@@ -1687,13 +1687,6 @@ webserver:
       type: string
       example: ~
       default: "False"
-    dag_default_view:
-      description: |
-        Default DAG view. Valid values are: ``grid``, ``graph``, ``duration``, ``gantt``, ``landing_times``
-      version_added: ~
-      type: string
-      example: ~
-      default: "grid"
     dag_orientation:
       description: |
         Default DAG orientation. Valid values are:

diff --git a/airflow/configuration.py b/airflow/configuration.py
@@ -358,7 +358,6 @@ def inversed_deprecated_sections(self):
         },
         "webserver": {
             "navbar_color": (re.compile(r"(?i)^#007A87$"), "#fff", "2.1"),
-            "dag_default_view": (re.compile(r"^tree$"), "grid", "3.0"),
         },
         "email": {
             "email_backend": (

diff --git a/airflow/dag_processing/collection.py b/airflow/dag_processing/collection.py
@@ -426,7 +426,6 @@ def update_dags(
             dm.is_active = True
             dm.has_import_errors = False
             dm.last_parsed_time = utcnow()
-            dm.default_view = dag.default_view or conf.get("webserver", "dag_default_view").lower()
             if hasattr(dag, "_dag_display_property_value"):
                 dm._dag_display_property_value = dag._dag_display_property_value
             elif dag.dag_display_name != dag.dag_id:

diff --git a/airflow/migrations/versions/0062_3_0_0_remove_dag_default_view.py b/airflow/migrations/versions/0062_3_0_0_remove_dag_default_view.py
@@ -0,0 +1,48 @@
+#
+# 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.
+
+"""
+Remove dag.default_view column.
+
+Revision ID: 16f7f5ee874e
+Revises: cf87489a35df
+Create Date: 2025-03-11 10:39:25.449265
+
+"""
+
+from __future__ import annotations
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "16f7f5ee874e"
+down_revision = "cf87489a35df"
+branch_labels = None
+depends_on = None
+airflow_version = "3.0.0"
+
+
+def upgrade():
+    with op.batch_alter_table("dag", schema=None) as batch_op:
+        batch_op.drop_column("default_view")
+
+
+def downgrade():
+    with op.batch_alter_table("dag", schema=None) as batch_op:
+        batch_op.add_column(sa.Column("default_view", sa.VARCHAR(length=25), nullable=True))
diff --git a/airflow/models/dag.py b/airflow/models/dag.py
@@ -124,7 +124,6 @@
 
 log = logging.getLogger(__name__)
 
-DEFAULT_VIEW_PRESETS = ["grid", "graph", "duration", "gantt", "landing_times"]
 ORIENTATION_PRESETS = ["LR", "TB", "RL", "BT"]
 
 AssetT = TypeVar("AssetT", bound=BaseAsset)
@@ -380,8 +379,6 @@ class DAG(TaskSDKDag, LoggingMixin):
     :param dagrun_timeout: Specify the duration a DagRun should be allowed to run before it times out or
         fails. Task instances that are running when a DagRun is timed out will be marked as skipped.
     :param sla_miss_callback: DEPRECATED - The SLA feature is removed in Airflow 3.0, to be replaced with a new implementation in 3.1
-    :param default_view: Specify DAG default view (grid, graph, duration,
-                                                   gantt, landing_times), default grid
     :param orientation: Specify DAG orientation in graph view (LR, TB, RL, BT), default LR
     :param catchup: Perform scheduler catchup (or only run latest)? Defaults to True
     :param on_failure_callback: A function or list of functions to be called when a DagRun of this dag fails.
@@ -428,7 +425,6 @@ class DAG(TaskSDKDag, LoggingMixin):
     partial: bool = False
     last_loaded: datetime | None = attrs.field(factory=timezone.utcnow)
 
-    default_view: str = airflow_conf.get_mandatory_value("webserver", "dag_default_view").lower()
     orientation: str = airflow_conf.get_mandatory_value("webserver", "dag_orientation")
 
     # this will only be set at serialization time
@@ -1901,13 +1897,6 @@ def sync_to_db(self, session=NEW_SESSION):
         bundle_version = self.get_bundle_version(session=session)
         self.bulk_write_to_db(bundle_name, bundle_version, [self], session=session)
 
-    def get_default_view(self):
-        """Allow backward compatible jinja2 templates."""
-        if self.default_view is None:
-            return airflow_conf.get("webserver", "dag_default_view").lower()
-        else:
-            return self.default_view
-
     @staticmethod
     @provide_session
     def deactivate_unknown_dags(active_dag_ids, session=NEW_SESSION):
@@ -2084,8 +2073,6 @@ class DagModel(Base):
     _dag_display_property_value = Column("dag_display_name", String(2000), nullable=True)
     # Description of the dag
     description = Column(Text)
-    # Default view of the DAG inside the webserver
-    default_view = Column(String(25))
     # Timetable summary
     timetable_summary = Column(Text, nullable=True)
     # Timetable description
@@ -2235,11 +2222,6 @@ def get_paused_dag_ids(dag_ids: list[str], session: Session = NEW_SESSION) -> se
         paused_dag_ids = {paused_dag_id for (paused_dag_id,) in paused_dag_ids}
         return paused_dag_ids
 
-    def get_default_view(self) -> str:
-        """Get the Default DAG View, returns the default config value if DagModel does not have a value."""
-        # This is for backwards-compatibility with old dags that don't have None as default_view
-        return self.default_view or airflow_conf.get_mandatory_value("webserver", "dag_default_view").lower()
-
     @property
     def safe_dag_id(self):
         return self.dag_id.replace(".", "__dot__")

diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py
@@ -1637,7 +1637,6 @@ class SerializedDAG(DAG, BaseSerialization):
     def __get_constructor_defaults():
         param_to_attr = {
             "description": "_description",
-            "default_view": "_default_view",
         }
         return {
             param_to_attr.get(k, k): v.default
@@ -1917,7 +1916,6 @@ class LazyDeserializedDAG(pydantic.BaseModel):
         "max_consecutive_failed_dag_runs",
         "owner_links",
         "access_control",
-        "default_view",
     }
 
     @property

diff --git a/airflow/ui/openapi-gen/requests/schemas.gen.ts b/airflow/ui/openapi-gen/requests/schemas.gen.ts
@@ -1589,17 +1589,6 @@ export const $DAGDetailsResponse = {
       ],
       title: "Last Expired",
     },
-    default_view: {
-      anyOf: [
-        {
-          type: "string",
-        },
-        {
-          type: "null",
-        },
-      ],
-      title: "Default View",
-    },
     fileloc: {
       type: "string",
       title: "Fileloc",
@@ -1884,7 +1873,6 @@ export const $DAGDetailsResponse = {
     "is_active",
     "last_parsed_time",
     "last_expired",
-    "default_view",
     "fileloc",
     "description",
     "timetable_summary",
@@ -1976,17 +1964,6 @@ export const $DAGResponse = {
       ],
       title: "Last Expired",
     },
-    default_view: {
-      anyOf: [
-        {
-          type: "string",
-        },
-        {
-          type: "null",
-        },
-      ],
-      title: "Default View",
-    },
     fileloc: {
       type: "string",
       title: "Fileloc",
@@ -2128,7 +2105,6 @@ export const $DAGResponse = {
     "is_active",
     "last_parsed_time",
     "last_expired",
-    "default_view",
     "fileloc",
     "description",
     "timetable_summary",
@@ -2776,17 +2752,6 @@ export const $DAGWithLatestDagRunsResponse = {
       ],
       title: "Last Expired",
     },
-    default_view: {
-      anyOf: [
-        {
-          type: "string",
-        },
-        {
-          type: "null",
-        },
-      ],
-      title: "Default View",
-    },
     fileloc: {
       type: "string",
       title: "Fileloc",
@@ -2935,7 +2900,6 @@ export const $DAGWithLatestDagRunsResponse = {
     "is_active",
     "last_parsed_time",
     "last_expired",
-    "default_view",
     "fileloc",
     "description",
     "timetable_summary",

diff --git a/airflow/ui/openapi-gen/requests/types.gen.ts b/airflow/ui/openapi-gen/requests/types.gen.ts
@@ -499,7 +499,6 @@ export type DAGDetailsResponse = {
   is_active: boolean;
   last_parsed_time: string | null;
   last_expired: string | null;
-  default_view: string | null;
   fileloc: string;
   description: string | null;
   timetable_summary: string | null;
@@ -562,7 +561,6 @@ export type DAGResponse = {
   is_active: boolean;
   last_parsed_time: string | null;
   last_expired: string | null;
-  default_view: string | null;
   fileloc: string;
   description: string | null;
   timetable_summary: string | null;
@@ -737,7 +735,6 @@ export type DAGWithLatestDagRunsResponse = {
   is_active: boolean;
   last_parsed_time: string | null;
   last_expired: string | null;
-  default_view: string | null;
   fileloc: string;
   description: string | null;
   timetable_summary: string | null;

diff --git a/airflow/ui/src/layouts/Details/DetailsLayout.tsx b/airflow/ui/src/layouts/Details/DetailsLayout.tsx
@@ -50,10 +50,7 @@ export const DetailsLayout = ({ children, error, isLoading, tabs }: Props) => {
 
   const { data: dag } = useDagServiceGetDag({ dagId });
 
-  const [dagView, setDagView] = useLocalStorage<"graph" | "grid">(
-    `dag_view-${dagId}`,
-    dag && (dag.default_view === "graph" || dag.default_view === "grid") ? dag.default_view : "grid",
-  );
+  const [dagView, setDagView] = useLocalStorage<"graph" | "grid">(`dag_view-${dagId}`, "grid");
 
   const { fitView, getZoom } = useReactFlow();
 

diff --git a/airflow/ui/src/mocks/handlers/dag.ts b/airflow/ui/src/mocks/handlers/dag.ts
@@ -27,7 +27,6 @@ export const MOCK_DAG = {
   dag_display_name: "tutorial_taskflow_api",
   dag_id: "tutorial_taskflow_api",
   dag_run_timeout: null,
-  default_view: "grid",
   description: null,
   doc_md:
     "\n    ### TaskFlow API Tutorial Documentation\n    This is a simple data pipeline example which demonstrates the use of\n    the TaskFlow API using three simple tasks for Extract, Transform, and Load.\n    Documentation that goes along with the Airflow TaskFlow API tutorial is\n    located\n    [here](https://airflow.apache.org/docs/apache-airflow/stable/tutorial_taskflow_api.html)\n    ",

diff --git a/airflow/ui/src/mocks/handlers/dags.ts b/airflow/ui/src/mocks/handlers/dags.ts
@@ -27,7 +27,6 @@ export const handlers: Array<HttpHandler> = [
     const successDag = {
       dag_display_name: "tutorial_taskflow_api_success",
       dag_id: "tutorial_taskflow_api_success",
-      default_view: "grid",
       file_token:
         ".eJw9yUsOgCAMBcC7cAB7JPISizR82kCJcnvjxtUsJlDWxlQwPEvhjU7TV0pk27N2goxU9f7lB80qxxPXJF-uQ1CjY5avI0wO2-EFouohiw.fhdU5u0Pb7lElEd-AUUXqjHSsdo",
       fileloc: "/airflow/dags/tutorial_taskflow_api.py",
@@ -64,7 +63,6 @@ export const handlers: Array<HttpHandler> = [
     const failedDag = {
       dag_display_name: "tutorial_taskflow_api_failed",
       dag_id: "tutorial_taskflow_api_failed",
-      default_view: "grid",
       file_token:
         ".eJw9yUsOgCAMBcC7cAB7JPISizR82kCJcnvjxtUsJlDWxlQwPEvhjU7TV0pk27N2goxU9f7lB80qxxPXJF-uQ1CjY5avI0wO2-EFouohiw.fhdU5u0Pb7lElEd-AUUXqjHSsdo",
       fileloc: "/airflow/dags/tutorial_taskflow_api_failed.py",
@@ -122,7 +120,6 @@ export const handlers: Array<HttpHandler> = [
     const failedDag = {
       dag_display_name: "tutorial_taskflow_api_failed",
       dag_id: "tutorial_taskflow_api_failed",
-      default_view: "grid",
       description: null,
       file_token:
         ".eJw9yUsOgCAMBcC7cAB7JPISizR82kCJcnvjxtUsJlDWxlQwPEvhjU7TV0pk27N2goxU9f7lB80qxxPXJF-uQ1CjY5avI0wO2-EFouohiw.fhdU5u0Pb7lElEd-AUUXqjHSsdo",
@@ -149,7 +146,6 @@ export const handlers: Array<HttpHandler> = [
     const successDag = {
       dag_display_name: "tutorial_taskflow_api_success",
       dag_id: "tutorial_taskflow_api_success",
-      default_view: "grid",
       description: null,
       file_token:
         ".eJw9yUsOgCAMBcC7cAB7JPISizR82kCJcnvjxtUsJlDWxlQwPEvhjU7TV0pk27N2goxU9f7lB80qxxPXJF-uQ1CjY5avI0wO2-EFouohiw.fhdU5u0Pb7lElEd-AUUXqjHSsdo",