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 <[email protected]> Authored: Tue May 10 15:08:11 2016 +0200 Committer: Dan Davydov <[email protected]> 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
