remove() should issue a close() on existing session

diff --git a/lib/sqlalchemy/orm/scoping.py b/lib/sqlalchemy/orm/scoping.py
index caa46670b9cfb1ebb7c0eb7500a56a8c9374d665..058c15cc96bf875eec979486c7908e59a960959f 100644 (file)
--- a/lib/sqlalchemy/orm/scoping.py
+++ b/lib/sqlalchemy/orm/scoping.py
@@ -44,6 +44,8 @@ class ScopedSession(object):
             return self.registry()
     
     def remove(self):
+        if self.registry.has():
+            self.registry().close()
         self.registry.clear()
     
     def mapper(self, *args, **kwargs):