Sprinkle a few more transaction API calls around to make sure the database

doesn't remain in a locked state, hosing other processes.

- Move a commit to the end of StockDatabase._create()
- Add an abort to the Exception clause if there's an error while dequeuing
- Add an abort to the Exception clause if there's an error while finishing
- Add a commit after _doperiodic() and _shortcircuit() is called.
- Add a commit to the end of cleaning_teardown() in test_documentation.py

This now makes all the tests pass even when all of them are run.

1 files changed, 4 insertions, 1 deletions

diff --git a/mailman/queue/__init__.py b/mailman/queue/__init__.py
index fb6b07479..e30608138 100644
--- a/mailman/queue/__init__.py
+++ b/mailman/queue/__init__.py
@@ -274,6 +274,7 @@ class Runner:
                 log.error('Skipping and preserving unparseable message: %s',
                           filebase)
                 self._switchboard.finish(filebase, preserve=True)
+                config.db.abort()
                 continue
             try:
                 self._onefile(msg, msgdata)
@@ -303,11 +304,13 @@ class Runner:
                     log.error('SHUNTING FAILED, preserving original entry: %s',
                               filebase)
                     self._switchboard.finish(filebase, preserve=True)
-            # Other work we want to do each time through the loop
+                    config.db.abort()
+            # Other work we want to do each time through the loop.
             Utils.reap(self._kids, once=True)
             self._doperiodic()
             if self._shortcircuit():
                 break
+            config.db.commit()
         return len(files)
 
     def _onefile(self, msg, msgdata):