Show "Task Reschedule" table in Airflow Webserver

airflow/www/extensions/init_views.py

@@ -50,6 +50,7 @@ def init_appbuilder_views(app):
     appbuilder.add_view(views.LogModelView, "Logs", category="Browse")
     appbuilder.add_view(views.SlaMissModelView, "SLA Misses", category="Browse")
     appbuilder.add_view(views.TaskInstanceModelView, "Task Instances", category="Browse")
+    appbuilder.add_view(views.TaskRescheduleModelView, "Task Reschedules", category="Browse")
     appbuilder.add_view(views.ConfigurationView, "Configurations", category="Admin", category_icon="fa-user")
     appbuilder.add_view(views.ConnectionModelView, "Connections", category="Admin")
     appbuilder.add_view(views.PoolModelView, "Pools", category="Admin")

airflow/www/views.py

@@ -2617,6 +2617,41 @@ class LogModelView(AirflowModelView):
     }
 
 
+class TaskRescheduleModelView(AirflowModelView):
+    """View to show records from Task Reschedule table"""
+    route_base = '/taskreschedule'
+
+    datamodel = AirflowModelView.CustomSQLAInterface(models.TaskReschedule)
+
+    base_permissions = ['can_list']
+
+    list_columns = ['id', 'dag_id', 'task_id', 'execution_date', 'try_number',
+                    'start_date', 'end_date', 'duration', 'reschedule_date']
+
+    search_columns = ['dag_id', 'task_id', 'execution_date', 'start_date', 'end_date',
+                      'reschedule_date']
+
+    base_order = ('id', 'desc')
+
+    base_filters = [['dag_id', DagFilter, lambda: []]]
+
+    def duration_f(attr):
+        end_date = attr.get('end_date')
+        duration = attr.get('duration')
+        if end_date and duration:
+            return timedelta(seconds=duration)
+
+    formatters_columns = {
+        'dag_id': wwwutils.dag_link,
+        'task_id': wwwutils.task_instance_link,
+        'start_date': wwwutils.datetime_f('start_date'),
+        'end_date': wwwutils.datetime_f('end_date'),
+        'execution_date': wwwutils.datetime_f('execution_date'),
+        'reschedule_date': wwwutils.datetime_f('reschedule_date'),
+        'duration': duration_f,
+    }
+
+
 class TaskInstanceModelView(AirflowModelView):
     """View to show records from TaskInstance table"""
     route_base = '/taskinstance'

tests/www/test_views.py

@@ -430,7 +430,7 @@ def prepare_dagruns(self):
             state=State.RUNNING)
 
     def test_index(self):
-        with assert_queries_count(39):
+        with assert_queries_count(40):
             resp = self.client.get('/', follow_redirects=True)
         self.check_content_in_response('DAGs', resp)
 
@@ -2227,6 +2227,18 @@ def test_start_date_filter(self):
         self.check_content_in_response('List Task Instance', resp)
 
 
+class TestTaskRescheduleView(TestBase):
+    TI_ENDPOINT = '/taskreschedule/list/?_flt_0_execution_date={}'
+
+    def test_start_date_filter(self):
+        resp = self.client.get(self.TI_ENDPOINT.format(
+            self.percent_encode('2018-10-09 22:44:31')))
+        # We aren't checking the logic of the date filter itself (that is built
+        # in to FAB) but simply that our UTC conversion was run - i.e. it
+        # doesn't blow up!
+        self.check_content_in_response('List Task Reschedule', resp)
+
+
 class TestRenderedView(TestBase):
 
     def setUp(self):