diff --git a/asyncdb/meta/recordset.py b/asyncdb/meta/recordset.py index e7101db9..5af7cce4 100644 --- a/asyncdb/meta/recordset.py +++ b/asyncdb/meta/recordset.py @@ -5,7 +5,7 @@ """ from collections.abc import Sequence, Iterator from typing import Any, Union -from google.cloud import bigquery +# from google.cloud import bigquery from .record import Record @@ -32,7 +32,8 @@ def get_result(self) -> Any: def from_result(cls, result: Iterator) -> "Recordset": cols = [] try: - if isinstance(result, bigquery.table.RowIterator): + # if isinstance(result, bigquery.table.RowIterator): + if hasattr(result, 'job_id'): # BigQuery Row Iterator rows_list = [row for row in result] result = [{key: value for key, value in row.items()} for row in rows_list] cols = list(result[0].keys()) diff --git a/asyncdb/version.py b/asyncdb/version.py index ce924773..4f2575c3 100644 --- a/asyncdb/version.py +++ b/asyncdb/version.py @@ -3,7 +3,7 @@ __title__ = "asyncdb" __description__ = "Library for Asynchronous data source connections \ Collection of asyncio drivers." -__version__ = "2.7.17" +__version__ = "2.7.18" __author__ = "Jesus Lara" __author_email__ = "jesuslarag@gmail.com" __license__ = "BSD"