diff options
| -rw-r--r-- | oslo_db/sqlalchemy/utils.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/oslo_db/sqlalchemy/utils.py b/oslo_db/sqlalchemy/utils.py index b54774d..02992f0 100644 --- a/oslo_db/sqlalchemy/utils.py +++ b/oslo_db/sqlalchemy/utils.py @@ -1227,12 +1227,16 @@ class NonCommittingConnectable(object): """ + _nested_trans = None + def __init__(self, connection): self.connection = connection self._trans = connection.begin() self._restart_nested() def _restart_nested(self): + if self._nested_trans is not None: + self._nested_trans.rollback() self._nested_trans = self.connection.begin_nested() def _dispose(self): |