1- from unittest .mock import MagicMock
1+ #
2+ # Copyright (c) 2012-2023 Snowflake Computing Inc. All rights reserved.
3+ #
4+
25from typing import Union
6+ from unittest .mock import MagicMock
37
48import pandas as pd
59import pytest
610
7- from .mock_utils import mock_connection
811from snowflake .connector import pandas_tools
912
13+ from .mock_utils import mock_connection
14+
1015
1116@pytest .mark .parametrize (
1217 ("use_vectorized_scanner" , "expected_file_format" ),
1318 [
1419 (None , "FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto)" ),
15- (True , "FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto USE_VECTORIZED_SCANNER=TRUE)" ),
16- (False , "FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto USE_VECTORIZED_SCANNER=FALSE)" ),
20+ (
21+ True ,
22+ "FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto USE_VECTORIZED_SCANNER=TRUE)" ,
23+ ),
24+ (
25+ False ,
26+ "FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto USE_VECTORIZED_SCANNER=FALSE)" ,
27+ ),
1728 ],
1829)
19- def test_write_pandas_use_vectorized_scanner (use_vectorized_scanner : Union [bool , None ], expected_file_format : str ):
30+ def test_write_pandas_use_vectorized_scanner (
31+ use_vectorized_scanner : Union [bool , None ], expected_file_format : str
32+ ):
2033 # Setup Mocks
2134 df = pd .DataFrame ({"col1" : [1 , 2 , 3 ]})
2235
@@ -34,12 +47,11 @@ def test_write_pandas_use_vectorized_scanner(use_vectorized_scanner: Union[bool,
3447 use_vectorized_scanner = use_vectorized_scanner ,
3548 )
3649
37- executed_sql_statements = [call [0 ][0 ] for call in mock_cursor .execute .call_args_list ]
50+ executed_sql_statements = [
51+ call [0 ][0 ] for call in mock_cursor .execute .call_args_list
52+ ]
3853
3954 assert any (
40- ' COPY INTO' in sql and expected_file_format in sql
55+ " COPY INTO" in sql and expected_file_format in sql
4156 for sql in executed_sql_statements
4257 )
43-
44-
45-
0 commit comments