Explorar o código

Redis result backend: Fix for chord error handling. Closes #2409

Ask Solem %!s(int64=9) %!d(string=hai) anos
pai
achega
760347e4d5
Modificáronse 1 ficheiros con 2 adicións e 0 borrados
  1. 2 0
      celery/backends/base.py

+ 2 - 0
celery/backends/base.py

@@ -241,6 +241,8 @@ class BaseBackend(object):
         return self.persistent if p is None else p
         return self.persistent if p is None else p
 
 
     def encode_result(self, result, status):
     def encode_result(self, result, status):
+        if isinstance(result, ExceptionInfo):
+            result = result.exception
         if status in self.EXCEPTION_STATES and isinstance(result, Exception):
         if status in self.EXCEPTION_STATES and isinstance(result, Exception):
             return self.prepare_exception(result)
             return self.prepare_exception(result)
         else:
         else: