Browse Source

Catch TimeoutError (long line fixed)

pull/635/head
oxid 4 years ago
parent
commit
b3043a8257
  1. 6
      socketio/redis_manager.py

6
socketio/redis_manager.py

@ -78,7 +78,8 @@ class RedisManager(PubSubManager): # pragma: no cover
if not retry: if not retry:
self._redis_connect() self._redis_connect()
return self.redis.publish(self.channel, pickle.dumps(data)) return self.redis.publish(self.channel, pickle.dumps(data))
except (redis.exceptions.ConnectionError, redis.exceptions.TimeoutError) as e: except (redis.exceptions.ConnectionError,
redis.exceptions.TimeoutError) as e:
if retry: if retry:
logger.error('Cannot publish to redis... retrying') logger.error('Cannot publish to redis... retrying')
retry = False retry = False
@ -96,7 +97,8 @@ class RedisManager(PubSubManager): # pragma: no cover
self.pubsub.subscribe(self.channel) self.pubsub.subscribe(self.channel)
for message in self.pubsub.listen(): for message in self.pubsub.listen():
yield message yield message
except (redis.exceptions.ConnectionError, redis.exceptions.TimeoutError) as e: except (redis.exceptions.ConnectionError,
redis.exceptions.TimeoutError) as e:
logger.error('Cannot receive from redis ({})... ' logger.error('Cannot receive from redis ({})... '
'retrying in {} secs'.format(e, retry_sleep)) 'retrying in {} secs'.format(e, retry_sleep))
connect = True connect = True

Loading…
Cancel
Save