diff options
author | Vitja Makarov <vitja.makarov@gmail.com> | 2013-09-04 23:36:41 +0400 |
---|---|---|
committer | Vitja Makarov <vitja.makarov@gmail.com> | 2013-09-04 23:42:16 +0400 |
commit | 22801335d2826a383edf4a0c020b5249bcea7d30 (patch) | |
tree | abe65b378c11d438e8bb78e4685c2429fc3c806e /redis/sentinel.py | |
parent | 232b815545c016bb2b6c862d6df8ec16e1c88088 (diff) | |
download | redis-py-22801335d2826a383edf4a0c020b5249bcea7d30.tar.gz |
PEP8 fix
Diffstat (limited to 'redis/sentinel.py')
-rw-r--r-- | redis/sentinel.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/redis/sentinel.py b/redis/sentinel.py index c41b9fe..d5f5726 100644 --- a/redis/sentinel.py +++ b/redis/sentinel.py @@ -29,7 +29,7 @@ class SentinelManagedConnection(Connection): def connect(self): if self._sock: - return # already connected + return # already connected if self.connection_pool.is_master: self.connect_to(self.connection_pool.get_master_address()) else: @@ -38,7 +38,7 @@ class SentinelManagedConnection(Connection): return self.connect_to(slave) except ConnectionError: continue - raise SlaveNotFoundError # Never be here + raise SlaveNotFoundError # Never be here class SentinelConnectionPool(ConnectionPool): @@ -69,7 +69,7 @@ class SentinelConnectionPool(ConnectionPool): elif self.master_address is None: self.master_address = master_address elif master_address != self.master_address: - self.disconnect() # Master address changed + self.disconnect() # Master address changed return master_address def rotate_slaves(self): @@ -80,7 +80,7 @@ class SentinelConnectionPool(ConnectionPool): self.slave_rr_counter = random.randint(0, len(slaves) - 1) for _ in xrange(len(slaves)): self.slave_rr_counter = ( - self.slave_rr_counter + 1) % len(slaves) + self.slave_rr_counter + 1) % len(slaves) slave = slaves[self.slave_rr_counter] yield slave # Fallback to the master connection @@ -132,8 +132,8 @@ class Sentinel(object): Asks sentinels for master's address corresponding to the service labeled ``service_name``. - Returns a pair (address, port) or raises MasterNotFoundError if no alive - master is found. + Returns a pair (address, port) or raises MasterNotFoundError if no + alive master is found. """ for sentinel_no, sentinel in enumerate(self.sentinels): try: |