harrywang
diff --git a/‎composer/workflows/airflow_db_cleanup.py
Copy file name to clipboardExpand all lines: composer/workflows/airflow_db_cleanup.py
+2-2Lines changed: 2 additions & 2 deletions b/‎composer/workflows/airflow_db_cleanup.py
Copy file name to clipboardExpand all lines: composer/workflows/airflow_db_cleanup.py
+2-2Lines changed: 2 additions & 2 deletions
@@ -109,7 +109,7 @@
     },
     {
         "airflow_db_model": TaskInstance,
-        "age_check_column": TaskInstance.execution_date
+        "age_check_column": TaskInstance.start_date
         if AIRFLOW_VERSION < ["2", "2", "0"]
         else TaskInstance.start_date,
         "keep_last": False,
@@ -174,7 +174,7 @@
     DATABASE_OBJECTS.append(
         {
             "airflow_db_model": TaskFail,
-            "age_check_column": TaskFail.execution_date,
+            "age_check_column": TaskFail.start_date,
             "keep_last": False,
             "keep_last_filters": None,
             "keep_last_group_by": None,