Forráskód Böngészése

handle GroupResults for non-pickle serializers

Steeve Morin 12 éve
szülő
commit
5a7ebe2f99
1 módosított fájl, 3 hozzáadás és 1 törlés
  1. 3 1
      celery/backends/base.py

+ 3 - 1
celery/backends/base.py

@@ -27,7 +27,7 @@ from celery import states
 from celery.app import current_task
 from celery.datastructures import LRUCache
 from celery.exceptions import TimeoutError, TaskRevokedError
-from celery.result import from_serializable
+from celery.result import from_serializable, GroupResult
 from celery.utils import timeutils
 from celery.utils.serialization import (
         get_pickled_exception,
@@ -137,6 +137,8 @@ class BaseBackend(object):
 
     def prepare_value(self, result):
         """Prepare value for storage."""
+        if isinstance(result, GroupResult):
+            return result.serializable()
         return result
 
     def forget(self, task_id):