update

Author: jaredmauch

Mailman/Handlers/ToOutgoing.py

@@ -26,7 +26,6 @@
 import traceback
 from Mailman.Logging.Syslog import mailman_log
 
-
 def process(mlist, msg, msgdata):
     """Process the message by moving it to the outgoing queue."""
     msgid = msg.get('message-id', 'n/a')

Mailman/Queue/IncomingRunner.py

@@ -197,38 +197,40 @@ def _get_pipeline(self, mlist, msg, msgdata):
 
     def _dopipeline(self, mlist, msg, msgdata, pipeline):
         msgid = msg.get('message-id', 'n/a')
-        mailman_log('qrunner', 'IncomingRunner._dopipeline: Starting pipeline processing for message %s', msgid)
+        mailman_log('debug', 'IncomingRunner._dopipeline: Starting pipeline processing for message %s', msgid)
 
         # Validate pipeline state - use a more lenient check
         if not pipeline:
-            mailman_log('qrunner', 'IncomingRunner._dopipeline: Empty pipeline for message %s', msgid)
+            mailman_log('debug', 'IncomingRunner._dopipeline: Empty pipeline for message %s', msgid)
             return 0
 
         # Deep copy the pipeline to prevent modifications
         current_pipeline = list(pipeline)
         if 'pipeline' in msgdata:
             stored_pipeline = list(msgdata['pipeline'])
             if set(current_pipeline) != set(stored_pipeline):
-                mailman_log('qrunner', 'IncomingRunner._dopipeline: Pipeline mismatch for message %s. Current: %s, Stored: %s', 
+                mailman_log('debug', 'IncomingRunner._dopipeline: Pipeline mismatch for message %s. Current: %s, Stored: %s', 
                            msgid, str(current_pipeline), str(stored_pipeline))
                 # Update the stored pipeline instead of failing
                 msgdata['pipeline'] = current_pipeline
 
         # Log message details for debugging
-        mailman_log('qrunner', 'IncomingRunner._dopipeline: Message details for %s:', msgid)
-        mailman_log('qrunner', '  From: %s', msg.get('from', 'unknown'))
-        mailman_log('qrunner', '  To: %s', msg.get('to', 'unknown'))
-        mailman_log('qrunner', '  Subject: %s', msg.get('subject', '(no subject)'))
-        mailman_log('qrunner', '  Message type: %s', type(msg).__name__)
-        mailman_log('qrunner', '  Message data: %s', str(msgdata))
+        mailman_log('debug', 'IncomingRunner._dopipeline: Message details for %s:', msgid)
+        mailman_log('debug', '  From: %s', msg.get('from', 'unknown'))
+        mailman_log('debug', '  To: %s', msg.get('to', 'unknown'))
+        mailman_log('debug', '  Subject: %s', msg.get('subject', '(no subject)'))
+        mailman_log('debug', '  Message type: %s', type(msg).__name__)
+        mailman_log('debug', '  Message data: %s', str(msgdata))
 
         # Process through pipeline
         for handler in current_pipeline:
             try:
+                mailman_log('debug', 'IncomingRunner._dopipeline: Processing message %s through handler %s', msgid, handler)
                 modname = 'Mailman.Handlers.' + handler
                 __import__(modname)
                 process = getattr(sys.modules[modname], 'process')
                 process(mlist, msg, msgdata)
+                mailman_log('debug', 'IncomingRunner._dopipeline: Successfully processed message %s through handler %s', msgid, handler)
             except ImportError as e:
                 mailman_log('error', 'Failed to import handler %s: %s', handler, str(e))
                 return 0
@@ -239,6 +241,7 @@ def _dopipeline(self, mlist, msg, msgdata, pipeline):
                 mailman_log('error', 'Handler %s failed: %s\n%s', handler, str(e), traceback.format_exc())
                 return 0
 
+        mailman_log('debug', 'IncomingRunner._dopipeline: Successfully completed pipeline processing for message %s', msgid)
         return 1
 
     def _cleanup(self):

Mailman/Queue/VirginRunner.py

@@ -146,9 +146,19 @@ def _dispose(self, listname, msg, msgdata):
             msgdata['_fasttrack'] = 1
             mailman_log('debug', 'VirginRunner: Set _fasttrack flag for message %s', msgid)
 
+            # Get the pipeline and log it
+            pipeline = self._get_pipeline(mlist, msg, msgdata)
+            mailman_log('debug', 'VirginRunner: Pipeline for message %s: %s', msgid, pipeline)
+            
             # Process through the pipeline
             mailman_log('debug', 'VirginRunner: Starting pipeline processing for message %s', msgid)
-            result = IncomingRunner._dispose(self, mlist, msg, msgdata)
+            try:
+                result = IncomingRunner._dispose(self, mlist, msg, msgdata)
+                mailman_log('debug', 'VirginRunner: Pipeline processing completed for message %s with result: %s', msgid, result)
+            except Exception as e:
+                mailman_log('error', 'VirginRunner: Pipeline processing failed for message %s: %s', msgid, str(e))
+                mailman_log('error', 'VirginRunner: Pipeline processing traceback:\n%s', traceback.format_exc())
+                raise
 
             # Log successful completion
             mailman_log('info', 'VirginRunner: Successfully processed virgin message %s (file: %s) for list %s',