Browse Source

Removed safe parameter due to PyMongo deprecation warning

rfkrocktk 12 years ago
parent
commit
aae9d28033
1 changed files with 3 additions and 3 deletions
  1. 3 3
      celery/backends/mongodb.py

+ 3 - 3
celery/backends/mongodb.py

@@ -128,7 +128,7 @@ class MongoBackend(BaseBackend):
                 'date_done': datetime.utcnow(),
                 'traceback': Binary(self.encode(traceback)),
                 'children': Binary(self.encode(self.current_task_children()))}
-        self.collection.save(meta, safe=True)
+        self.collection.save(meta)
 
         return result
 
@@ -155,7 +155,7 @@ class MongoBackend(BaseBackend):
         meta = {'_id': group_id,
                 'result': Binary(self.encode(result)),
                 'date_done': datetime.utcnow()}
-        self.collection.save(meta, safe=True)
+        self.collection.save(meta)
 
         return result
 
@@ -187,7 +187,7 @@ class MongoBackend(BaseBackend):
         # By using safe=True, this will wait until it receives a response from
         # the server.  Likewise, it will raise an OperationsError if the
         # response was unable to be completed.
-        self.collection.remove({'_id': task_id}, safe=True)
+        self.collection.remove({'_id': task_id})
 
     def cleanup(self):
         """Delete expired metadata."""