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 @@ -90,9 +90,6 @@ def __init__(
9090 )
9191 self ._retry_delay_default = kwargs .get ("_retry_delay_default" , 5.0 )
9292 self .force_dangerous_codes = kwargs .get ("_retry_dangerous_codes" , [])
93- self ._retry_server_directed_only = kwargs .get (
94- "_retry_server_directed_only" , False
95- )
9693
9794 # Connection pooling settings
9895 self .max_connections = kwargs .get ("max_connections" , 10 )
@@ -117,7 +114,7 @@ def __init__(
117114 stop_after_attempts_duration = self ._retry_stop_after_attempts_duration ,
118115 delay_default = self ._retry_delay_default ,
119116 force_dangerous_codes = self .force_dangerous_codes ,
120- server_directed_only = self . _retry_server_directed_only ,
117+ server_directed_only = kwargs . get ( " _retry_server_directed_only" , False ) ,
121118 urllib3_kwargs = urllib3_kwargs ,
122119 )
123120 else :
Original file line number Diff line number Diff line change @@ -189,9 +189,6 @@ def __init__(
189189 " This behaviour is deprecated and will be removed in a future release."
190190 )
191191 self .force_dangerous_codes = kwargs .get ("_retry_dangerous_codes" , [])
192- self ._retry_server_directed_only = kwargs .get (
193- "_retry_server_directed_only" , False
194- )
195192
196193 additional_transport_args = {}
197194
@@ -218,7 +215,7 @@ def __init__(
218215 stop_after_attempts_duration = self ._retry_stop_after_attempts_duration ,
219216 delay_default = self ._retry_delay_default ,
220217 force_dangerous_codes = self .force_dangerous_codes ,
221- server_directed_only = self . _retry_server_directed_only ,
218+ server_directed_only = kwargs . get ( " _retry_server_directed_only" , False ) ,
222219 urllib3_kwargs = urllib3_kwargs ,
223220 )
224221
You can’t perform that action at this time.
0 commit comments