Merge pull request #396 from reclosedev/sentinel-pool

Override _checkpid() in SentinelConnectionPool (#395)

1 files changed, 9 insertions, 0 deletions

diff --git a/redis/sentinel.py b/redis/sentinel.py
index bdb955f..8ba9920 100644
--- a/redis/sentinel.py
+++ b/redis/sentinel.py
@@ -1,3 +1,4 @@
+import os
 import random
 
 from redis.client import StrictRedis
@@ -90,6 +91,14 @@ class SentinelConnectionPool(ConnectionPool):
             pass
         raise SlaveNotFoundError('No slave found for %r' % (self.service_name))
 
+    def _checkpid(self):
+        if self.pid != os.getpid():
+            self.disconnect()
+            self.__init__(self.service_name, self.sentinel_manager,
+                          connection_class=self.connection_class,
+                          max_connections=self.max_connections,
+                          **self.connection_kwargs)
+
 
 class Sentinel(object):
     """