fix for connection loss on redis.flush

ckan · Mar 20, 2012 · 7fcd834 · 7fcd834
1 parent 2675b2a
commit 7fcd834
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ckan/config/middleware.py b/ckan/config/middleware.py
@@ -220,6 +220,8 @@ def _start_response(status, response_headers, exc_info=None):
                 self.redis_connection = self.redis.StrictRedis()
                 self.redis_connection.flushdb()
             except self.redis_exception:
+                # Connection may have failed at flush so clear it.
+                self.redis_connection = None
                 return self.app(environ, start_response)
 
         # If cached return cached result