Skip to content

Commit d9a4797

Browse files
fix check-types
Signed-off-by: Vikrant Puppala <vikrant.puppala@databricks.com>
1 parent 3847aca commit d9a4797

File tree

2 files changed

+37
-43
lines changed

2 files changed

+37
-43
lines changed

src/databricks/sql/auth/common.py

Lines changed: 16 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -40,17 +40,17 @@ def __init__(
4040
# HTTP client configuration parameters
4141
ssl_options=None, # SSLOptions type
4242
socket_timeout: Optional[float] = None,
43-
retry_stop_after_attempts_count: int = 5,
44-
retry_delay_min: float = 1.0,
45-
retry_delay_max: float = 60.0,
46-
retry_stop_after_attempts_duration: float = 900.0,
47-
retry_delay_default: float = 5.0,
43+
retry_stop_after_attempts_count: Optional[int] = None,
44+
retry_delay_min: Optional[float] = None,
45+
retry_delay_max: Optional[float] = None,
46+
retry_stop_after_attempts_duration: Optional[float] = None,
47+
retry_delay_default: Optional[float] = None,
4848
retry_dangerous_codes: Optional[List[int]] = None,
4949
http_proxy: Optional[str] = None,
5050
proxy_username: Optional[str] = None,
5151
proxy_password: Optional[str] = None,
52-
pool_connections: int = 10,
53-
pool_maxsize: int = 20,
52+
pool_connections: Optional[int] = None,
53+
pool_maxsize: Optional[int] = None,
5454
user_agent: Optional[str] = None,
5555
):
5656
self.hostname = hostname
@@ -71,17 +71,19 @@ def __init__(
7171
# HTTP client configuration
7272
self.ssl_options = ssl_options
7373
self.socket_timeout = socket_timeout
74-
self.retry_stop_after_attempts_count = retry_stop_after_attempts_count
75-
self.retry_delay_min = retry_delay_min
76-
self.retry_delay_max = retry_delay_max
77-
self.retry_stop_after_attempts_duration = retry_stop_after_attempts_duration
78-
self.retry_delay_default = retry_delay_default
74+
self.retry_stop_after_attempts_count = retry_stop_after_attempts_count or 5
75+
self.retry_delay_min = retry_delay_min or 1.0
76+
self.retry_delay_max = retry_delay_max or 10.0
77+
self.retry_stop_after_attempts_duration = (
78+
retry_stop_after_attempts_duration or 300.0
79+
)
80+
self.retry_delay_default = retry_delay_default or 5.0
7981
self.retry_dangerous_codes = retry_dangerous_codes or []
8082
self.http_proxy = http_proxy
8183
self.proxy_username = proxy_username
8284
self.proxy_password = proxy_password
83-
self.pool_connections = pool_connections
84-
self.pool_maxsize = pool_maxsize
85+
self.pool_connections = pool_connections or 10
86+
self.pool_maxsize = pool_maxsize or 20
8587
self.user_agent = user_agent
8688

8789

src/databricks/sql/utils.py

Lines changed: 21 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from __future__ import annotations
2-
from typing import Dict, List, Optional, Union
2+
from typing import Any, Dict, List, Optional, Tuple, Union, Sequence
33

44
from dateutil import parser
55
import datetime
@@ -9,7 +9,6 @@
99
from collections.abc import Mapping
1010
from decimal import Decimal
1111
from enum import Enum
12-
from typing import Any, Dict, List, Optional, Tuple, Union, Sequence
1312
import re
1413

1514
import lz4.frame
@@ -906,30 +905,23 @@ def build_client_context(server_hostname: str, version: str, **kwargs):
906905
else:
907906
user_agent = f"PyDatabricksSqlConnector/{version}"
908907

909-
# Build ClientContext kwargs, excluding None values to use defaults
910-
context_kwargs = {
911-
"hostname": server_hostname,
912-
"ssl_options": ssl_options,
913-
"user_agent": user_agent,
914-
}
915-
916-
# Only add non-None values to let defaults work
917-
for param, kwarg_key in [
918-
("socket_timeout", "_socket_timeout"),
919-
("retry_stop_after_attempts_count", "_retry_stop_after_attempts_count"),
920-
("retry_delay_min", "_retry_delay_min"),
921-
("retry_delay_max", "_retry_delay_max"),
922-
("retry_stop_after_attempts_duration", "_retry_stop_after_attempts_duration"),
923-
("retry_delay_default", "_retry_delay_default"),
924-
("retry_dangerous_codes", "_retry_dangerous_codes"),
925-
("http_proxy", "_http_proxy"),
926-
("proxy_username", "_proxy_username"),
927-
("proxy_password", "_proxy_password"),
928-
("pool_connections", "_pool_connections"),
929-
("pool_maxsize", "_pool_maxsize"),
930-
]:
931-
value = kwargs.get(kwarg_key)
932-
if value is not None:
933-
context_kwargs[param] = value
934-
935-
return ClientContext(**context_kwargs)
908+
# Explicitly construct ClientContext with proper types
909+
return ClientContext(
910+
hostname=server_hostname,
911+
ssl_options=ssl_options,
912+
user_agent=user_agent,
913+
socket_timeout=kwargs.get("_socket_timeout"),
914+
retry_stop_after_attempts_count=kwargs.get("_retry_stop_after_attempts_count"),
915+
retry_delay_min=kwargs.get("_retry_delay_min"),
916+
retry_delay_max=kwargs.get("_retry_delay_max"),
917+
retry_stop_after_attempts_duration=kwargs.get(
918+
"_retry_stop_after_attempts_duration"
919+
),
920+
retry_delay_default=kwargs.get("_retry_delay_default"),
921+
retry_dangerous_codes=kwargs.get("_retry_dangerous_codes"),
922+
http_proxy=kwargs.get("_http_proxy"),
923+
proxy_username=kwargs.get("_proxy_username"),
924+
proxy_password=kwargs.get("_proxy_password"),
925+
pool_connections=kwargs.get("_pool_connections"),
926+
pool_maxsize=kwargs.get("_pool_maxsize"),
927+
)

0 commit comments

Comments
 (0)