From fb9257917c47f9d250167a919be39b84caf965ad Mon Sep 17 00:00:00 2001 From: chr Date: Thu, 2 Apr 2020 21:54:01 -0700 Subject: [PATCH] fix that bug --- message_queue.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/message_queue.py b/message_queue.py index acb91c8..50ee2b3 100644 --- a/message_queue.py +++ b/message_queue.py @@ -64,7 +64,7 @@ class SocketWrapper: LOG.debug("Connecting to {}:{}".format(self.host, self.port)) self.soc = _try_with_backoff( lambda: socket.create_connection((self.host, self.port)), - lambda e: e is OSError and e.errno == 111, + lambda e: isinstance(e, OSError) and e.errno == 111, ) LOG.info("Socket Connected") @@ -72,7 +72,7 @@ class SocketWrapper: LOG.info("Server Binding to {}:{}".format(self.host, self.port)) self.soc = _try_with_backoff( lambda: socket_create_server((self.host, self.port)), - lambda e: e is OSError and e.errno == 98, + lambda e: isinstance(e, OSError) and e.errno == 98, ) LOG.info("Server Bound")