You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2016/10/28 14:00:12 UTC
incubator-airflow git commit: [AIRFLOW-568] Fix double task_stats
count if a DagRun is active
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 <dg...@pandora.com>
Authored: Fri Oct 28 15:59:44 2016 +0200
Committer: Bolke de Bruin <bo...@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')
)