https://issues.apache.org/jira/browse/AIRFLOW-988

AIRFLOW_988.diff

--- a/usr/local/lib/python2.7/site-packages/airflow/jobs.py
+++ b/usr/local/lib/python2.7/site-packages/airflow/jobs.py
@@ -35,7 +35,7 @@ import time
 from time import sleep

 import psutil
-from sqlalchemy import Column, Integer, String, DateTime, func, Index, or_
+from sqlalchemy import Column, Integer, String, DateTime, func, Index, or_, and_
 from sqlalchemy.exc import OperationalError
 from sqlalchemy.orm.session import make_transient
 from tabulate import tabulate
@@ -606,8 +606,8 @@ class SchedulerJob(BaseJob):
         slas = (
             session
             .query(SlaMiss)
-            .filter(or_(SlaMiss.email_sent == False,
-                        SlaMiss.notification_sent == False))
+            .filter(and_(SlaMiss.email_sent == False,
+                         SlaMiss.notification_sent == False))
             .filter(SlaMiss.dag_id == dag.dag_id)
             .all()
         )

apply_patch.sh

#!/bin/bash
patch -u airflow/jobs.py < AIRFLOW_988.diff