Clear UPSTREAM_FAILED using the clean cli (apache#3886)

* [AIRFLOW-1298] Fix 'clear only_failed' * [AIRFLOW-1298] Fix 'clear only_failed'
cfei18 · Jan 23, 2019 · 5dbda81 · 5dbda81
1 parent 3d87232
commit 5dbda81
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/airflow/models.py b/airflow/models.py
@@ -4070,7 +4070,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)