airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: AIRFLOW-92 Avoid unneeded upstream_failed session closes apache/incubator-airflow#1485
Date Tue, 10 May 2016 17:19:29 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/airbnb_rb1.7.1_3 77c7bc4ac -> 4a5f4a0ba


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/4a5f4a0b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/4a5f4a0b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/4a5f4a0b

Branch: refs/heads/airbnb_rb1.7.1_3
Commit: 4a5f4a0badfde97bd158f53513dab17450f8658b
Parents: 77c7bc4
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Tue May 10 15:08:11 2016 +0200
Committer: Dan Davydov <dan.davydov@airbnb.com>
Committed: Tue May 10 10:18:59 2016 -0700

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


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/4a5f4a0b/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index 58d6fd8..24ee0f5 100644
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -826,6 +826,7 @@ class TaskInstance(Base):
         self.start_date = datetime.now()
         self.end_date = datetime.now()
         session.merge(self)
+        session.commit()
 
     def is_queueable(
             self,
@@ -1064,7 +1065,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