File tree Expand file tree Collapse file tree 2 files changed +10
-3
lines changed Expand file tree Collapse file tree 2 files changed +10
-3
lines changed Original file line number Diff line number Diff line change @@ -214,7 +214,9 @@ def read(self) -> Optional[OAuthToken]:
214
214
# use_cloud_fetch
215
215
# Enable use of cloud fetch to extract large query results in parallel via cloud storage
216
216
217
- logger .debug (f"Connection.__init__(server_hostname={ server_hostname } , http_path={ http_path } )" )
217
+ logger .debug (
218
+ f"Connection.__init__(server_hostname={ server_hostname } , http_path={ http_path } )"
219
+ )
218
220
219
221
if access_token :
220
222
access_token_kv = {"access_token" : access_token }
Original file line number Diff line number Diff line change @@ -131,7 +131,9 @@ def __init__(
131
131
# max_download_threads
132
132
# Number of threads for handling cloud fetch downloads. Defaults to 10
133
133
134
- logger .debug (f"ThriftBackend.__init__(server_hostname={ server_hostname } , port={ port } , http_path={ http_path } )" )
134
+ logger .debug (
135
+ f"ThriftBackend.__init__(server_hostname={ server_hostname } , port={ port } , http_path={ http_path } )"
136
+ )
135
137
136
138
port = port or 443
137
139
if kwargs .get ("_connection_uri" ):
@@ -894,7 +896,10 @@ def execute_command(
894
896
):
895
897
assert session_handle is not None
896
898
897
- logger .debug (f"ThriftBackend.execute_command(operation={ operation } , session_handle={ session_handle } )" )
899
+ logger .debug (
900
+ f"ThriftBackend.execute_command(operation={ operation } , session_handle={ session_handle } )"
901
+ )
902
+
898
903
spark_arrow_types = ttypes .TSparkArrowTypes (
899
904
timestampAsArrow = self ._use_arrow_native_timestamps ,
900
905
decimalAsArrow = self ._use_arrow_native_decimals ,
You can’t perform that action at this time.
0 commit comments