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-353] Fix dag run status update failure
Date Tue, 23 Aug 2016 17:59:40 GMT
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 <yiqing_jin@apple.com>
Authored: Tue Aug 23 19:53:02 2016 +0200
Committer: Bolke de Bruin <bolke@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)


Mime
View raw message