CancelledError shouldn't be logged as request failure (#45)

Author: ciscorn

elasticsearch_async/connection.py

@@ -99,6 +99,9 @@ def perform_request(self, method, url, params=None, body=None, timeout=None, ign
                 raw_data = yield from response.text()
             duration = self.loop.time() - start
 
+        except asyncio.CancelledError:
+            raise
+
         except Exception as e:
             self.log_request_fail(method, url, url_path, body, self.loop.time() - start, exception=e)
             if isinstance(e, ServerFingerprintMismatch):

elasticsearch_async/connection_pool.py

@@ -9,8 +9,8 @@ def __init__(self, connections, loop, **kwargs):
         super().__init__(connections, **kwargs)
 
     async def close(self):
-        await asyncio.gather(*[conn.close() for conn in self.orig_connections],
-                             loop=self.loop)
+        await asyncio.wait([conn.close() for conn in self.orig_connections],
+                           loop=self.loop)
 
 
 class AsyncDummyConnectionPool(DummyConnectionPool):