From b3043a82572722a64521fa7dd15b61f01e789812 Mon Sep 17 00:00:00 2001 From: oxid Date: Wed, 10 Feb 2021 20:23:57 +0300 Subject: [PATCH] Catch TimeoutError (long line fixed) --- socketio/redis_manager.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/socketio/redis_manager.py b/socketio/redis_manager.py index 9ce0b44..8b419ba 100644 --- a/socketio/redis_manager.py +++ b/socketio/redis_manager.py @@ -78,7 +78,8 @@ class RedisManager(PubSubManager): # pragma: no cover if not retry: self._redis_connect() 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: logger.error('Cannot publish to redis... retrying') retry = False @@ -96,7 +97,8 @@ class RedisManager(PubSubManager): # pragma: no cover self.pubsub.subscribe(self.channel) for message in self.pubsub.listen(): 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 ({})... ' 'retrying in {} secs'.format(e, retry_sleep)) connect = True