diff --git a/aiogremlin/driver/cluster.py b/aiogremlin/driver/cluster.py index 9895cda..5f2aebc 100644 --- a/aiogremlin/driver/cluster.py +++ b/aiogremlin/driver/cluster.py @@ -117,8 +117,8 @@ async def get_connection(self, hostname=None): 'Unknown host: {}'.format(hostname)) else: host = self._hosts.popleft() - conn = await host.get_connection() self._hosts.append(host) + conn = await host.get_connection() return conn async def establish_hosts(self):