Prevent sequential scan of task instance table (#8014)

The exact dag_id is known so no need to perform a like here which caused a sequential scan.
apache · Mar 31, 2020 · cfc0d6c · cfc0d6c
1 parent 2503857
commit cfc0d6c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/models/dag.py b/airflow/models/dag.py
@@ -978,7 +978,7 @@ def clear(
             conditions = []
             for dag in self.subdags + [self]:
                 conditions.append(
-                    TI.dag_id.like(dag.dag_id) &
+                    (TI.dag_id == dag.dag_id) &
                     TI.task_id.in_(dag.task_ids)
                 )
             tis = tis.filter(or_(*conditions))