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/08/23 17:59:40 UTC
incubator-airflow git commit: [AIRFLOW-353] Fix dag run status update
failure
Repository: incubator-airflow
Updated Branches:
refs/heads/master b9858ed93 -> 901b60bac
[AIRFLOW-353] Fix dag run status update failure
When multiple tasks gets removed update status
fails as the list is updated in place.
Closes #1675 from yiqingj/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/901b60ba
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/901b60ba
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/901b60ba
Branch: refs/heads/master
Commit: 901b60bacc3ccbede8a8348dbd16aad08bc62c5c
Parents: b9858ed
Author: Yiqing Jin <yi...@apple.com>
Authored: Tue Aug 23 19:53:02 2016 +0200
Committer: Bolke de Bruin <bo...@xs4all.nl>
Committed: Tue Aug 23 19:58:53 2016 +0200
----------------------------------------------------------------------
airflow/models.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/901b60ba/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index 9eefaf3..01a51eb 100644
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -3866,7 +3866,7 @@ class DagRun(Base):
logging.info("Updating state for {} considering {} task(s)"
.format(self, len(tis)))
- for ti in tis:
+ for ti in list(tis):
# skip in db?
if ti.state == State.REMOVED:
tis.remove(ti)