Skip to content

Commit 6f812ef

Browse files
Catch all possible Redis errors (Fixes #635)
1 parent 5418098 commit 6f812ef

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

socketio/redis_manager.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ def _publish(self, data):
7878
if not retry:
7979
self._redis_connect()
8080
return self.redis.publish(self.channel, pickle.dumps(data))
81-
except redis.exceptions.ConnectionError:
81+
except redis.exceptions.RedisError:
8282
if retry:
8383
logger.error('Cannot publish to redis... retrying')
8484
retry = False
@@ -97,7 +97,7 @@ def _redis_listen_with_retries(self):
9797
retry_sleep = 1
9898
for message in self.pubsub.listen():
9999
yield message
100-
except redis.exceptions.ConnectionError:
100+
except redis.exceptions.RedisError:
101101
logger.error('Cannot receive from redis... '
102102
'retrying in {} secs'.format(retry_sleep))
103103
connect = True

0 commit comments

Comments
 (0)