From a6be8f9ec00e65e43aa03bf469a3f7a4e6dcbe6a Mon Sep 17 00:00:00 2001 From: mklokocka Date: Mon, 23 Jul 2018 23:53:02 +0200 Subject: [PATCH] fix _exit_event.set in __aexit__ coroutine of paginator --- aiocassandra.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiocassandra.py b/aiocassandra.py index bf53af9..3c5d7e1 100644 --- a/aiocassandra.py +++ b/aiocassandra.py @@ -74,7 +74,7 @@ async def __aenter__(self): return self async def __aexit__(self, *exc_info): - self._exit_event.set() + self._loop.call_soon_threadsafe(self._finish_event.set) _len = len(self._deque) self._deque.clear() logger.debug(