Py3 compatibility

Arkoniak · Aug 14, 2015 · 999d16f · 999d16f
1 parent 516f49e
commit 999d16f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/airflow/models.py b/airflow/models.py
@@ -679,10 +679,10 @@ def are_dependencies_met(
             qry = (
                 session
                 .query(
-                    func.sum(
-                        case([(TI.state == State.SUCCESS, 1)], else_=0)),
-                    func.sum(
-                        case([(TI.state == State.SKIPPED, 1)], else_=0)),
+                    func.coalesce(func.sum(
+                        case([(TI.state == State.SUCCESS, 1)], else_=0)), 0),
+                    func.coalesce(func.sum(
+                        case([(TI.state == State.SKIPPED, 1)], else_=0)), 0),
                     func.count(TI.task_id),
                 )
                 .filter(