@@ -828,7 +828,7 @@ def test_create_arrow_table_raises_error_for_unsupported_type(self):
828
828
t_row_set = ttypes .TRowSet ()
829
829
thrift_backend = ThriftBackend ("foobar" , 443 , "path" , [])
830
830
with self .assertRaises (OperationalError ):
831
- thrift_backend ._create_arrow_table (t_row_set , None , Mock ())
831
+ thrift_backend ._create_arrow_table (t_row_set , Mock (), None , Mock ())
832
832
833
833
@patch .object (ThriftBackend , "_convert_arrow_based_set_to_arrow_table" )
834
834
@patch .object (ThriftBackend , "_convert_column_based_set_to_arrow_table" )
@@ -841,16 +841,17 @@ def test_create_arrow_table_calls_correct_conversion_method(self, convert_col_mo
841
841
schema = Mock ()
842
842
cols = Mock ()
843
843
arrow_batches = Mock ()
844
+ are_arrow_results_compressed = Mock ()
844
845
description = Mock ()
845
846
846
847
t_col_set = ttypes .TRowSet (columns = cols )
847
- thrift_backend ._create_arrow_table (t_col_set , schema , description )
848
+ thrift_backend ._create_arrow_table (t_col_set , are_arrow_results_compressed , schema , description )
848
849
convert_arrow_mock .assert_not_called ()
849
850
convert_col_mock .assert_called_once_with (cols , description )
850
851
851
852
t_arrow_set = ttypes .TRowSet (arrowBatches = arrow_batches )
852
- thrift_backend ._create_arrow_table (t_arrow_set , schema , Mock ())
853
- convert_arrow_mock .assert_called_once_with (arrow_batches , schema )
853
+ thrift_backend ._create_arrow_table (t_arrow_set , are_arrow_results_compressed , schema , Mock ())
854
+ convert_arrow_mock .assert_called_once_with (arrow_batches , are_arrow_results_compressed , schema )
854
855
855
856
def test_convert_column_based_set_to_arrow_table_without_nulls (self ):
856
857
# Deliberately duplicate the column name to check that dups work
0 commit comments