From 11dca3e1ea8adf9470314772685facb512760268 Mon Sep 17 00:00:00 2001
From: Leifur Halldor Asgeirsson <lasgeirsson@zerofail.com>
Date: Fri, 14 Oct 2016 15:50:06 -0400
Subject: [PATCH] pass loop explicitly to asyncio.gather in pool, cluster
---
goblin/driver/cluster.py | 2 +-
goblin/driver/pool.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/goblin/driver/cluster.py b/goblin/driver/cluster.py
index f7952d7..0cab896 100644
--- a/goblin/driver/cluster.py
+++ b/goblin/driver/cluster.py
@@ -194,5 +194,5 @@ class Cluster:
while self._hosts:
host = self._hosts.popleft()
waiters.append(host.close())
- await asyncio.gather(*waiters)
+ await asyncio.gather(*waiters, loop=self._loop)
self._closed = True
diff --git a/goblin/driver/pool.py b/goblin/driver/pool.py
index 3df37de..8b231ae 100644
--- a/goblin/driver/pool.py
+++ b/goblin/driver/pool.py
@@ -211,7 +211,7 @@ class ConnectionPool:
while self._acquired:
conn = self._acquired.popleft()
waiters.append(conn.close())
- await asyncio.gather(*waiters)
+ await asyncio.gather(*waiters, loop=self._loop)
async def _get_connection(self, username, password, max_inflight,
response_timeout, message_serializer):
--
GitLab