Avoid thread to stop if there is an error in processNext

zopefoundation · May 16, 2011 · 7020cb2 · 7020cb2
1 parent d98fa21
commit 7020cb2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/docs/HISTORY.txt b/docs/HISTORY.txt
@@ -4,7 +4,7 @@ Changelog
 0.1-alpha-4 (unreleased)
 ------------------------
 
-- Nothing changed yet.
+- Avoid thread to stop if there is an error in processNext
 
 
 0.1-alpha-3 (2010-11-19)

diff --git a/src/z3c/taskqueue/processor.py b/src/z3c/taskqueue/processor.py
@@ -88,7 +88,11 @@ def processNext(self, jobid=None):
 
     def __call__(self):
         while self.running:
-            result = self.processNext()
+            try:
+                result = self.processNext()
+            except Exception, error:
+                log.exception(error)
+                result = None
             # If there are no jobs available, sleep a little bit and then
             # check again.
             if not result: