airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-568] Fix double task_stats count if a DagRun is active
Date Fri, 28 Oct 2016 14:00:12 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 97934318b -> 6f4704a44


[AIRFLOW-568] Fix double task_stats count if a DagRun is active

Closes #1836 from dgies/master


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/6f4704a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/6f4704a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/6f4704a4

Branch: refs/heads/master
Commit: 6f4704a447756d6a17c617afe1a9b54d629c79ac
Parents: 9793431
Author: Daniel Gies <dgies@pandora.com>
Authored: Fri Oct 28 15:59:44 2016 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Fri Oct 28 15:59:48 2016 +0200

----------------------------------------------------------------------
 airflow/www/views.py | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/6f4704a4/airflow/www/views.py
----------------------------------------------------------------------
diff --git a/airflow/www/views.py b/airflow/www/views.py
index 36384d8..c5666a0 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -511,6 +511,7 @@ class Airflow(BaseView):
 
         LastDagRun = (
             session.query(DagRun.dag_id, sqla.func.max(DagRun.execution_date).label('execution_date'))
+            .filter(DagRun.state != State.RUNNING)
             .group_by(DagRun.dag_id)
             .subquery('last_dag_run')
         )


Mime
View raw message