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