summaryrefslogtreecommitdiff
path: root/Mailman/Queue/IncomingRunner.py
diff options
context:
space:
mode:
authorbwarsaw2001-04-02 06:07:05 +0000
committerbwarsaw2001-04-02 06:07:05 +0000
commit9565d23ccfb7e7a7a0915baff5b20f9762db58a6 (patch)
tree70d6913169c233ea9fcfe61f58baf7805dd0ef9b /Mailman/Queue/IncomingRunner.py
parenta8602a427e5e9cefd8f3b6d67a74886ad6f8c041 (diff)
downloadmailman-9565d23ccfb7e7a7a0915baff5b20f9762db58a6.tar.gz
mailman-9565d23ccfb7e7a7a0915baff5b20f9762db58a6.tar.zst
mailman-9565d23ccfb7e7a7a0915baff5b20f9762db58a6.zip
_dispose(): Fix a bug whereby if an uncaught exception occurred, the
unprocessed pipeline module list wouldn't get saved in the message metadata.
Diffstat (limited to 'Mailman/Queue/IncomingRunner.py')
-rw-r--r--Mailman/Queue/IncomingRunner.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/Mailman/Queue/IncomingRunner.py b/Mailman/Queue/IncomingRunner.py
index cf57f68dd..2a051eebb 100644
--- a/Mailman/Queue/IncomingRunner.py
+++ b/Mailman/Queue/IncomingRunner.py
@@ -109,7 +109,10 @@ class IncomingRunner(Runner):
# used. Final fallback is the global pipeline.
try:
pipeline = self._get_pipeline(mlist, msg, msgdata)
- return self._dopipeline(mlist, msg, msgdata, pipeline)
+ status = self._dopipeline(mlist, msg, msgdata, pipeline)
+ if status:
+ msgdata['pipeline'] = pipeline
+ return status
finally:
mlist.Save()
mlist.Unlock()