@@ -146,11 +146,11 @@ def test_socket_timeout_passthrough(self, mock_client_class):
146
146
@patch ("%s.session.ThriftDatabricksClient" % PACKAGE_NAME )
147
147
def test_configuration_passthrough (self , mock_client_class ):
148
148
mock_session_config = Mock ()
149
-
149
+
150
150
# Create a mock SessionId that will be returned by open_session
151
151
mock_session_id = SessionId (BackendType .THRIFT , b"\x22 " , b"\x33 " )
152
152
mock_client_class .return_value .open_session .return_value = mock_session_id
153
-
153
+
154
154
databricks .sql .connect (
155
155
session_configuration = mock_session_config , ** self .DUMMY_CONNECTION_ARGS
156
156
)
@@ -171,11 +171,11 @@ def test_initial_namespace_passthrough(self, mock_client_class):
171
171
databricks .sql .connect (
172
172
** self .DUMMY_CONNECTION_ARGS , catalog = mock_cat , schema = mock_schem
173
173
)
174
-
174
+
175
175
# Check that open_session was called with the correct catalog and schema as positional arguments
176
176
call_args = mock_client_class .return_value .open_session .call_args [0 ]
177
- self .assertEqual (call_args [1 ], mock_cat ) # catalog is second positional argument
178
- self .assertEqual (call_args [2 ], mock_schem ) # schema is third positional argument
177
+ self .assertEqual (call_args [1 ], mock_cat )
178
+ self .assertEqual (call_args [2 ], mock_schem )
179
179
180
180
@patch ("%s.session.ThriftDatabricksClient" % PACKAGE_NAME )
181
181
def test_finalizer_closes_abandoned_connection (self , mock_client_class ):
0 commit comments