Solution (#50624): Airflow 3.0.x : Bring back from Airflow 2.x "Status of all previo

path/to/airflow-webserver/__init__.py

@@ -0,0 +1,5 @@
+from flask import Flask
+from .views import init_app
+
+app = Flask(__name__)
+init_app(app)

path/to/airflow-webserver/app.js

@@ -0,0 +1 @@
+// No changes needed

path/to/airflow-webserver/routes.js

@@ -0,0 +1 @@
+// No changes needed

path/to/airflow-webserver/services.js

@@ -0,0 +1 @@
+// No changes needed

path/to/airflow-webserver/templates/dags.html

@@ -0,0 +1,21 @@
+{% extends 'base.html' %}
+
+{% block content %}
+  <h1>DAGs</h1>
+  <table>
+    <thead>
+      <tr>
+        <th>DAG ID</th>
+        <th>Previous Run Status</th>
+      </tr>
+    </thead>
+    <tbody>
+      {% for dag in dags %}
+        <tr>
+          <td>{{ dag.dag_id }}</td>
+          <td>{{ previous_runs[loop.index0]['status'] }}</td>
+        </tr>
+      {% endfor %}
+    </tbody>
+  </table>
+{% endblock %}

path/to/airflow-webserver/views/__init__.py

@@ -0,0 +1,4 @@
+from .dags import dags_blueprint
+
+def init_app(app):
+    app.register_blueprint(dags_blueprint)

path/to/airflow-webserver/views/dags.py

@@ -0,0 +1,22 @@
+from airflow import settings
+from airflow.models import DagModel
+from airflow.utils import timezone
+from flask import Blueprint, render_template
+
+dags_blueprint = Blueprint('dags', __name__, template_folder='templates')
+
+@dags_blueprint.route('/dags')
+def dags():
+    # Get all DAGs
+    dags = DagModel.query.all()
+
+    # Get the status of all previous DAG runs
+    previous_runs = []
+    for dag in dags:
+        runs = DagModel.query.filter_by(dag_id=dag.dag_id).order_by(DagModel.run_id.desc()).all()
+        previous_runs.append({
+            'dag_id': dag.dag_id,
+            'status': 'success' if runs[0].state == 'success' else 'failure'
+        })
+
+    return render_template('dags.html', dags=dags, previous_runs=previous_runs)