Pārlūkot izejas kodu

allow EagerResult to be saved in TaskSetResult - closes GH-288

Norman Richards 14 gadi atpakaļ
vecāks
revīzija
4d5ac47471
1 mainītis faili ar 3 papildinājumiem un 0 dzēšanām
  1. 3 0
      celery/result.py

+ 3 - 0
celery/result.py

@@ -461,6 +461,9 @@ class EagerResult(BaseAsyncResult):
         self._state = state
         self._traceback = traceback
 
+    def __reduce__(self):
+        return (self.__class__, (self.task_id, self._result, self._state,  self._traceback))
+
     def successful(self):
         """Returns :const:`True` if the task executed without failure."""
         return self.state == states.SUCCESS