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-92 Avoid unneeded upstream_failed session closes apache/incubator-airflow#1485
Date Tue, 10 May 2016 13:12:17 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 40b3fffa0 -> dddfd3b5b


AIRFLOW-92 Avoid unneeded upstream_failed session closes apache/incubator-airflow#1485


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

Branch: refs/heads/master
Commit: dddfd3b5bf2cabaac6eec123dfa3cb59e73a56f5
Parents: 40b3fff
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Tue May 10 15:08:11 2016 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Tue May 10 15:08:11 2016 +0200

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


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/dddfd3b5/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index da11e6d..7618bd5 100644
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -868,6 +868,7 @@ class TaskInstance(Base):
         self.start_date = datetime.now()
         self.end_date = datetime.now()
         session.merge(self)
+        session.commit()
 
     def is_queueable(
             self,
@@ -1106,7 +1107,6 @@ class TaskInstance(Base):
             session=session, successes=successes, skipped=skipped,
             failed=failed, upstream_failed=upstream_failed, done=done,
             flag_upstream_failed=flag_upstream_failed)
-        session.commit()
         if verbose and not satisfied:
             logging.warning("Trigger rule `{}` not satisfied".format(task.trigger_rule))
         return satisfied


Mime
View raw message