diff options
| -rw-r--r-- | redis/sentinel.py | 9 |
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): """ |