File tree Expand file tree Collapse file tree 2 files changed +2
-8
lines changed
src/databricks/sql/backend Expand file tree Collapse file tree 2 files changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -92,9 +92,6 @@ def __init__(
9292 )
9393 self ._retry_delay_default = kwargs .get ("_retry_delay_default" , 5.0 )
9494 self .force_dangerous_codes = kwargs .get ("_retry_dangerous_codes" , [])
95- self ._retry_server_directed_only = kwargs .get (
96- "_retry_server_directed_only" , False
97- )
9895
9996 # Connection pooling settings
10097 self .max_connections = kwargs .get ("max_connections" , 10 )
@@ -119,7 +116,7 @@ def __init__(
119116 stop_after_attempts_duration = self ._retry_stop_after_attempts_duration ,
120117 delay_default = self ._retry_delay_default ,
121118 force_dangerous_codes = self .force_dangerous_codes ,
122- server_directed_only = self . _retry_server_directed_only ,
119+ server_directed_only = kwargs . get ( " _retry_server_directed_only" , False ) ,
123120 urllib3_kwargs = urllib3_kwargs ,
124121 )
125122 else :
Original file line number Diff line number Diff line change @@ -191,9 +191,6 @@ def __init__(
191191 " This behaviour is deprecated and will be removed in a future release."
192192 )
193193 self .force_dangerous_codes = kwargs .get ("_retry_dangerous_codes" , [])
194- self ._retry_server_directed_only = kwargs .get (
195- "_retry_server_directed_only" , False
196- )
197194
198195 additional_transport_args = {}
199196
@@ -220,7 +217,7 @@ def __init__(
220217 stop_after_attempts_duration = self ._retry_stop_after_attempts_duration ,
221218 delay_default = self ._retry_delay_default ,
222219 force_dangerous_codes = self .force_dangerous_codes ,
223- server_directed_only = self . _retry_server_directed_only ,
220+ server_directed_only = kwargs . get ( " _retry_server_directed_only" , False ) ,
224221 urllib3_kwargs = urllib3_kwargs ,
225222 )
226223
You can’t perform that action at this time.
0 commit comments