diff --git a/opensearchpy/connection_pool.py b/opensearchpy/connection_pool.py index e853849a..8790fcfa 100644 --- a/opensearchpy/connection_pool.py +++ b/opensearchpy/connection_pool.py @@ -174,7 +174,6 @@ def mark_dead(self, connection, now=None): """ # allow inject for testing purposes now = now if now else time.time() - print(id(connection), now) try: self.connections.remove(connection) except ValueError: @@ -188,7 +187,6 @@ def mark_dead(self, connection, now=None): dead_count = self.dead_count.get(connection, 0) + 1 self.dead_count[connection] = dead_count timeout = self.dead_timeout * 2 ** min(dead_count - 1, self.timeout_cutoff) - #time.sleep(.00001) self.dead.put((now + timeout,id(connection),connection)) logger.warning( "Connection %r has failed for %i times in a row, putting on %i second timeout.",