Only set an ERROR state if there's an ERROR handler.

fon-khan · Feb 26, 2013 · 8eb3a3a · 8eb3a3a
1 parent e232808
commit 8eb3a3a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lamson/routing.py b/lamson/routing.py
@@ -55,7 +55,6 @@
 import re
 import logging
 import sys
-import email.utils
 import shelve
 import threading
 
@@ -379,7 +378,8 @@ def call_safely(self, func, message, kwargs):
         except SMTPError:
             raise
         except:
-            self.set_state(func.__module__, message, 'ERROR')
+            if 'ERROR' in dir(sys.modules[func.__module__]):
+                self.set_state(func.__module__, message, 'ERROR')
 
             if self.UNDELIVERABLE_QUEUE:
                 self.UNDELIVERABLE_QUEUE.push(message)