Fix celery#5917

hicay · Jan 14, 2020 · 2919b37 · 2919b37
1 parent d056305
commit 2919b37
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/celery/backends/mongodb.py b/celery/backends/mongodb.py
@@ -180,7 +180,9 @@ def encode(self, data):
     def decode(self, data):
         if self.serializer == 'bson':
             return data
-        return super(MongoBackend, self).decode(data)
+
+        payload = self.encode(data)
+        return super(MongoBackend, self).decode(payload)
 
     def _store_result(self, task_id, result, state,
                       traceback=None, request=None, **kwargs):