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

Redis result backend: Fixes compat issue with redis-py 2.4.4

Ask Solem 14 éve
szülő
commit
742ac27634
1 módosított fájl, 1 hozzáadás és 9 törlés
  1. 1 9
      celery/backends/pyredis.py

+ 1 - 9
celery/backends/pyredis.py

@@ -72,12 +72,8 @@ class RedisBackend(KeyValueStoreBackend):
     def delete(self, key):
         self.client.delete(key)
 
-    def close(self):
-        """Closes the Redis connection."""
-        del(self.client)
-
     def process_cleanup(self):
-        self.close()
+        pass
 
     @cached_property
     def client(self):
@@ -85,7 +81,3 @@ class RedisBackend(KeyValueStoreBackend):
                                 port=self.redis_port,
                                 db=self.redis_db,
                                 password=self.redis_password)
-
-    @client.deleter
-    def client(self, client):
-        client.connection.disconnect()