MaybeEncodingError was not wrapped in ExceptionInfo. Thanks to mtirsel.

Closes celery#524
grzegorzlyczba · Nov 7, 2011 · c5244e7 · c5244e7
1 parent 71af08a
commit c5244e7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/celery/concurrency/processes/pool.py b/celery/concurrency/processes/pool.py
@@ -198,8 +198,10 @@ def poll(timeout):  # noqa
         try:
             put((READY, (job, i, result)))
         except Exception, exc:
+            _, _, tb = sys.exc_info()
             wrapped = MaybeEncodingError(exc, result[1])
-            put((READY, (job, i, (False, wrapped))))
+            einfo = ExceptionInfo((MaybeEncodingError, wrapped, tb))
+            put((READY, (job, i, (False, einfo))))
 
         completed += 1
     debug('worker exiting after %d tasks' % completed)