diff --git a/redis/sentinel.py b/redis/sentinel.py index 518fec582f..91231ed248 100644 --- a/redis/sentinel.py +++ b/redis/sentinel.py @@ -104,6 +104,7 @@ def get_master_address(self): self.master_address = master_address elif master_address != self.master_address: # Master address changed, disconnect all clients in this pool + self.master_address = master_address self.disconnect() return master_address