airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From san...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-400] models.py/DAG.set_dag_runs_state() does not correctly set state
Date Sat, 06 Aug 2016 17:07:09 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master c56793060 -> d69fb31dd


[AIRFLOW-400] models.py/DAG.set_dag_runs_state() does not correctly set state

Closes #1710 from normster/set_dag_runs_state


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

Branch: refs/heads/master
Commit: d69fb31dd19855b38a5a48050a28f969040e8f9d
Parents: c567930
Author: Norman Mu <norman@agari.com>
Authored: Sat Aug 6 10:06:52 2016 -0700
Committer: Siddharth Anand <siddharthanand@yahoo.com>
Committed: Sat Aug 6 10:06:52 2016 -0700

----------------------------------------------------------------------
 airflow/models.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/d69fb31d/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index 8326a92..45a9a43 100644
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -2919,7 +2919,7 @@ class DAG(BaseDag, LoggingMixin):
         dates = utils_date_range(start_date, end_date)
         drs = session.query(DagModel).filter_by(dag_id=self.dag_id).all()
         for dr in drs:
-            dr.state = State.RUNNING
+            dr.state = state
 
     def clear(
             self, start_date=None, end_date=None,


Mime
View raw message