diff --git a/airflow/models.py b/airflow/models.py
index 86a9cc2fc6a99..4b4554ff597a6 100755
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -3821,7 +3821,9 @@ def clear(
         if end_date:
             tis = tis.filter(TI.execution_date <= end_date)
         if only_failed:
-            tis = tis.filter(TI.state == State.FAILED)
+            tis = tis.filter(or_(
+                TI.state == State.FAILED,
+                TI.state == State.UPSTREAM_FAILED))
         if only_running:
             tis = tis.filter(TI.state == State.RUNNING)