Default socket timeout to 15 min

src/databricks/sql/thrift_backend.py

@@ -99,8 +99,8 @@ def __init__(
         # _retry_stop_after_attempts_count
         #  The maximum number of times we should retry retryable requests (defaults to 24)
         # _socket_timeout
-        #  The timeout in seconds for socket send, recv and connect operations. Defaults to None for
-        #  no timeout. Should be a positive float or integer.
+        #  The timeout in seconds for socket send, recv and connect operations. Should be a positive float or integer.
+        #  (defaults to 60)
 
         port = port or 443
         if kwargs.get("_connection_uri"):
@@ -152,8 +152,12 @@ def __init__(
             ssl_context=ssl_context,
         )
 
-        timeout = kwargs.get("_socket_timeout")
-        # setTimeout defaults to None (i.e. no timeout), and is expected in ms
+        timeout = (
+            60
+            if kwargs.get("_socket_timeout") is None
+            else kwargs.get("_socket_timeout")
+        )
+        # setTimeout defaults to 60 seconds and is expected in ms
         self._transport.setTimeout(timeout and (float(timeout) * 1000.0))
 
         self._transport.setCustomHeaders(dict(http_headers))

tests/e2e/driver_tests.py

@@ -459,7 +459,7 @@ def test_temp_view_fetch(self):
 
     @skipIf(pysql_has_version('<', '2'), 'requires pysql v2')
     def test_socket_timeout(self):
-        #  We we expect to see a BlockingIO error when the socket is opened
+        #  We expect to see a BlockingIO error when the socket is opened
         #  in non-blocking mode, since no poll is done before the read
         with self.assertRaises(OperationalError) as cm:
             with self.cursor({"_socket_timeout": 0}):

tests/unit/test_thrift_backend.py

@@ -218,7 +218,7 @@ def test_socket_timeout_is_propagated(self, t_http_client_class):
         ThriftBackend("hostname", 123, "path_value", [], auth_provider=AuthProvider(), _socket_timeout=0)
         self.assertEqual(t_http_client_class.return_value.setTimeout.call_args[0][0], 0)
         ThriftBackend("hostname", 123, "path_value", [], auth_provider=AuthProvider(), _socket_timeout=None)
-        self.assertEqual(t_http_client_class.return_value.setTimeout.call_args[0][0], None)
+        self.assertEqual(t_http_client_class.return_value.setTimeout.call_args[0][0], 60 * 1000)
 
     def test_non_primitive_types_raise_error(self):
         columns = [