diff --git a/dlt/destinations/impl/bigquery/sql_client.py b/dlt/destinations/impl/bigquery/sql_client.py index f3c853faad..c375ff2d32 100644 --- a/dlt/destinations/impl/bigquery/sql_client.py +++ b/dlt/destinations/impl/bigquery/sql_client.py @@ -48,7 +48,7 @@ class BigQueryDBApiCursorImpl(DBApiCursorImpl): def df(self, chunk_size: int = None, **kwargs: Any) -> DataFrame: if chunk_size is not None: return super().df(chunk_size=chunk_size) - query_job: bigquery.QueryJob = self.native_cursor._query_job # type: ignore + query_job: bigquery.QueryJob = getattr(self.native_cursor, "_query_job", self.native_cursor.query_job) # type: ignore try: return query_job.to_dataframe(**kwargs)