diff --git a/aiocassandra.py b/aiocassandra.py index bf53af9..18ed07b 100644 --- a/aiocassandra.py +++ b/aiocassandra.py @@ -36,6 +36,8 @@ def __init__(self, request, *, executor, loop): self.__pages = set() def _handle_page(self, rows): + if rows is None: + rows = list() if self._exit_event.is_set(): _len = len(rows) logger.debug(