Jelajahi Sumber

do not destroy connection to mongo

Valentyn Klindukh 9 tahun lalu
induk
melakukan
bc373013d8
1 mengubah file dengan 0 tambahan dan 8 penghapusan
  1. 0 8
      celery/backends/mongodb.py

+ 0 - 8
celery/backends/mongodb.py

@@ -162,14 +162,6 @@ class MongoBackend(BaseBackend):
 
 
         return self._connection
         return self._connection
 
 
-    def process_cleanup(self):
-        if self._connection is not None:
-            # MongoDB connection will be closed automatically when object
-            # goes out of scope
-            del(self.collection)
-            del(self.database)
-            self._connection = None
-
     def encode(self, data):
     def encode(self, data):
         if self.serializer == 'bson':
         if self.serializer == 'bson':
             # mongodb handles serialization
             # mongodb handles serialization