Browse Source

Revert "Deserialize json string prior to inclusion in CouchDB doc"

This reverts commit ccf65f80d75accbbdec7b1cf99c3d9475eef3e5a.
Andrew Stewart 8 years ago
parent
commit
af34680f84
1 changed files with 2 additions and 7 deletions
  1. 2 7
      celery/backends/couchdb.py

+ 2 - 7
celery/backends/couchdb.py

@@ -8,8 +8,6 @@
 """
 from __future__ import absolute_import, unicode_literals
 
-import json
-
 try:
     import pycouchdb
 except ImportError:
@@ -93,16 +91,13 @@ class CouchBackend(KeyValueStoreBackend):
             return None
 
     def set(self, key, value):
-        # data = {'_id': key, 'value': value}
-        data = json.loads(value)
-        data['_id'] = key
+        data = {'_id': key, 'value': value}
         try:
             self.connection.save(data)
         except pycouchdb.exceptions.Conflict:
             # document already exists, update it
             data = self.connection.get(key)
-            # data['value'] = value
-            data.update(json.loads(value))            
+            data['value'] = value
             self.connection.save(data)
 
     def mget(self, keys):