diff options
| -rw-r--r-- | Mailman/Queue/IncomingRunner.py | 5 |
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() |