Update redis_cache.py
moving logging as well
This commit is contained in:
@@ -208,12 +208,12 @@ class RedisClient(object):
|
|||||||
|
|
||||||
def retry_call(self, key, f, time_expire, with_lock):
|
def retry_call(self, key, f, time_expire, with_lock):
|
||||||
self.RETRIES += 1
|
self.RETRIES += 1
|
||||||
if self.RETRIES <= self.MAX_RETRIES:
|
if self.RETRIES <= self.MAX_RETRIES:
|
||||||
logger.error("sleeping %s seconds before reconnecting" % (2 * self.RETRIES))
|
|
||||||
time.sleep(2 * self.RETRIES)
|
|
||||||
if self.fail_gracefully:
|
if self.fail_gracefully:
|
||||||
self.RETRIES = 0
|
self.RETRIES = 0
|
||||||
return f()
|
return f()
|
||||||
|
logger.error("sleeping %s seconds before reconnecting" % (2 * self.RETRIES))
|
||||||
|
time.sleep(2 * self.RETRIES)
|
||||||
return self.__call__(key, f, time_expire, with_lock)
|
return self.__call__(key, f, time_expire, with_lock)
|
||||||
else:
|
else:
|
||||||
self.RETRIES = 0
|
self.RETRIES = 0
|
||||||
|
|||||||
Reference in New Issue
Block a user