From 02a34d05c2497971c2f51d2d63ef23fb259a039f Mon Sep 17 00:00:00 2001 From: Neil Booth Date: Sun, 5 Aug 2018 12:10:34 +0900 Subject: [PATCH] async/await fixes --- electrumx/server/session.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/electrumx/server/session.py b/electrumx/server/session.py index ecbdb2b..1dc778e 100644 --- a/electrumx/server/session.py +++ b/electrumx/server/session.py @@ -434,7 +434,7 @@ class SessionManager(object): # Close servers and sessions self.state = self.SHUTTING_DOWN await self._close_servers(list(self.servers.keys())) - with TaskGroup() as group: + async with TaskGroup() as group: for session in list(self.sessions): await group.spawn(await session.close(force_after=0.1)) @@ -631,7 +631,7 @@ class ElectrumX(SessionBase): async def close(self, force_after=30): '''Close the connection and return when closed.''' async with ignore_after(force_after): - super().close() + await super().close() self.abort() async def daemon_request(self, method, *args):