1
- from unittest .mock import MagicMock
1
+ #
2
+ # Copyright (c) 2012-2023 Snowflake Computing Inc. All rights reserved.
3
+ #
4
+
2
5
from typing import Union
6
+ from unittest .mock import MagicMock
3
7
4
8
import pandas as pd
5
9
import pytest
6
10
7
- from .mock_utils import mock_connection
8
11
from snowflake .connector import pandas_tools
9
12
13
+ from .mock_utils import mock_connection
14
+
10
15
11
16
@pytest .mark .parametrize (
12
17
("use_vectorized_scanner" , "expected_file_format" ),
13
18
[
14
19
(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
+ ),
17
28
],
18
29
)
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
+ ):
20
33
# Setup Mocks
21
34
df = pd .DataFrame ({"col1" : [1 , 2 , 3 ]})
22
35
@@ -34,12 +47,11 @@ def test_write_pandas_use_vectorized_scanner(use_vectorized_scanner: Union[bool,
34
47
use_vectorized_scanner = use_vectorized_scanner ,
35
48
)
36
49
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
+ ]
38
53
39
54
assert any (
40
- ' COPY INTO' in sql and expected_file_format in sql
55
+ " COPY INTO" in sql and expected_file_format in sql
41
56
for sql in executed_sql_statements
42
57
)
43
-
44
-
45
-
0 commit comments