@@ -46,7 +46,7 @@ def __init__(
4646 description = None ,
4747 is_staging_operation : bool = False ,
4848 lz4_compressed : bool = False ,
49- arrow_schema_bytes : bytes = b"" ,
49+ arrow_schema_bytes : Optional [ bytes ] = b"" ,
5050 ):
5151 """
5252 A ResultSet manages the results of a single command.
@@ -182,17 +182,16 @@ def __init__(
182182 :param is_direct_results: Whether there are more rows to fetch
183183 """
184184 # Initialize ThriftResultSet-specific attributes
185- self ._arrow_schema_bytes = execute_response .arrow_schema_bytes
186185 self ._use_cloud_fetch = use_cloud_fetch
187186 self .is_direct_results = is_direct_results
188187
189188 # Build the results queue if t_row_set is provided
190189 results_queue = None
191190 if t_row_set and execute_response .result_format is not None :
192- from databricks .sql .utils import ThriftResultSetQueueFactory
191+ from databricks .sql .utils import ResultSetQueueFactory
193192
194193 # Create the results queue using the provided format
195- results_queue = ThriftResultSetQueueFactory .build_queue (
194+ results_queue = ResultSetQueueFactory .build_queue (
196195 row_set_type = execute_response .result_format ,
197196 t_row_set = t_row_set ,
198197 arrow_schema_bytes = execute_response .arrow_schema_bytes or b"" ,
0 commit comments