Skip to content

Commit a6788f8

Browse files
remove duplicate queue init (merge artifact)
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent c7b0701 commit a6788f8

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

src/databricks/sql/result_set.py

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -186,22 +186,6 @@ def __init__(
186186
self._use_cloud_fetch = use_cloud_fetch
187187
self.is_direct_results = is_direct_results
188188

189-
# Build the results queue if t_row_set is provided
190-
results_queue = None
191-
if t_row_set and execute_response.result_format is not None:
192-
from databricks.sql.utils import ResultSetQueueFactory
193-
194-
# Create the results queue using the provided format
195-
results_queue = ResultSetQueueFactory.build_queue(
196-
row_set_type=execute_response.result_format,
197-
t_row_set=t_row_set,
198-
arrow_schema_bytes=execute_response.arrow_schema_bytes or b"",
199-
max_download_threads=max_download_threads,
200-
lz4_compressed=execute_response.lz4_compressed,
201-
description=execute_response.description,
202-
ssl_options=ssl_options,
203-
)
204-
205189
# Build the results queue if t_row_set is provided
206190
results_queue = None
207191
if t_row_set and execute_response.result_format is not None:

0 commit comments

Comments
 (0)