You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by sa...@apache.org on 2016/08/06 17:07:09 UTC
incubator-airflow git commit: [AIRFLOW-400]
models.py/DAG.set_dag_runs_state() does not correctly set state
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 <no...@agari.com>
Authored: Sat Aug 6 10:06:52 2016 -0700
Committer: Siddharth Anand <si...@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,