Commit b9093889 by Joseph Mulloy

Add newlines to satisfy pep8/flake8

parent e1c7861e
...@@ -6,21 +6,25 @@ import backoff ...@@ -6,21 +6,25 @@ import backoff
max_tries = 5 max_tries = 5
class RedisWrapper(object): class RedisWrapper(object):
def __init__(self, *args, **kwargs): def __init__(self, *args, **kwargs):
self.redis = redis.StrictRedis(*args, **kwargs) self.redis = redis.StrictRedis(*args, **kwargs)
@backoff.on_exception(backoff.expo, @backoff.on_exception(backoff.expo,
(redis.exceptions.TimeoutError, (redis.exceptions.TimeoutError,
redis.exceptions.ConnectionError), redis.exceptions.ConnectionError),
max_tries=max_tries) max_tries=max_tries)
def keys(self): def keys(self):
return self.redis.keys() return self.redis.keys()
@backoff.on_exception(backoff.expo, @backoff.on_exception(backoff.expo,
(redis.exceptions.TimeoutError, (redis.exceptions.TimeoutError,
redis.exceptions.ConnectionError), redis.exceptions.ConnectionError),
max_tries=max_tries) max_tries=max_tries)
def type(self, key): def type(self, key):
return self.redis.type(key) return self.redis.type(key)
@backoff.on_exception(backoff.expo, @backoff.on_exception(backoff.expo,
(redis.exceptions.TimeoutError, (redis.exceptions.TimeoutError,
redis.exceptions.ConnectionError), redis.exceptions.ConnectionError),
...@@ -28,14 +32,17 @@ class RedisWrapper(object): ...@@ -28,14 +32,17 @@ class RedisWrapper(object):
def llen(self, key): def llen(self, key):
return self.redis.llen(key) return self.redis.llen(key)
class CwBotoWrapper(object): class CwBotoWrapper(object):
def __init__(self): def __init__(self):
self.cw = boto3.client('cloudwatch') self.cw = boto3.client('cloudwatch')
@backoff.on_exception(backoff.expo, @backoff.on_exception(backoff.expo,
(botocore.exceptions.ClientError), (botocore.exceptions.ClientError),
max_tries=max_tries) max_tries=max_tries)
def list_metrics(self, *args, **kwargs): def list_metrics(self, *args, **kwargs):
return self.cw.list_metrics(*args, **kwargs) return self.cw.list_metrics(*args, **kwargs)
@backoff.on_exception(backoff.expo, @backoff.on_exception(backoff.expo,
(botocore.exceptions.ClientError), (botocore.exceptions.ClientError),
max_tries=max_tries) max_tries=max_tries)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment