vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Switch socket_timeout to socket_connect_timeout for redis.

Browse source
This commit is contained in:
Jake Moshenko 2014-09-23 14:58:46 -04:00
parent 26fab5d6ba
commit 74e35f917e
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
data/buildlogs.py
View file

@ -17,7 +17,7 @@ class RedisBuildLogs(object):
PHASE = 'phase'
def __init__(self, redis_host):
self._redis = redis.StrictRedis(host=redis_host, socket_timeout=5)
self._redis = redis.StrictRedis(host=redis_host, socket_connect_timeout=5)
@staticmethod
def _logs_key(build_id):

4
data/userevent.py
View file

@ -44,7 +44,7 @@ class UserEvent(object):
as backed by Redis.
"""
def __init__(self, redis_host, username):
self._redis = redis.StrictRedis(host=redis_host, socket_timeout=5)
self._redis = redis.StrictRedis(host=redis_host, socket_connect_timeout=5)
self._username = username
@staticmethod
@ -77,7 +77,7 @@ class UserEventListener(object):
def __init__(self, redis_host, username, events=set([])):
channels = [self._user_event_key(username, e) for e in events]
self._redis = redis.StrictRedis(host=redis_host, socket_timeout=5)
self._redis = redis.StrictRedis(host=redis_host, socket_connect_timeout=5)
self._pubsub = self._redis.pubsub()
self._pubsub.subscribe(channels)