Commit nested transactions when exiting the context

pugsql/compiler.py

@@ -3,11 +3,12 @@
 """
 from . import parser, context
 from .exceptions import NoConnectionError
-from contextlib import contextmanager
+from contextlib import contextmanager, suppress
 from glob import glob
 import os
 from sqlalchemy import create_engine
 from sqlalchemy.orm import sessionmaker
+from sqlalchemy.exc import ResourceClosedError
 import threading
 import re
 
@@ -127,6 +128,9 @@ def transaction(self):
             except Exception as e:
                 session.rollback()
                 raise e
+            else:
+                with suppress(ResourceClosedError):
+                    session.commit()
 
     def _execute(self, clause, *multiparams, **params):
         if getattr(self._locals, 'session', None):