We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 78cfd27 commit f94adefCopy full SHA for f94adef
src/databricks/sql/result_set.py
@@ -126,8 +126,6 @@ def __init__(
126
self._fill_results_buffer()
127
128
def _fill_results_buffer(self):
129
- """Fill the results buffer using the ThriftDatabricksClient directly."""
130
- # Use the thrift_client (backend) directly to fetch results
131
results, has_more_rows = self.backend.fetch_results(
132
op_handle=self.command_id,
133
max_rows=self.arraysize,
@@ -302,7 +300,6 @@ def fetchone(self) -> Optional[Row]:
302
300
Fetch the next row of a query result set, returning a single sequence,
303
301
or None when no more data is available.
304
"""
305
-
306
if isinstance(self.results, ColumnQueue):
307
res = self._convert_columnar_table(self.fetchmany_columnar(1))
308
else:
0 commit comments