correct session logic after duplication during merge

Author: varun-edachali-dbx

src/databricks/sql/backend/thrift_backend.py

@@ -939,7 +939,7 @@ def execute_command(
         logger.debug(
             "ThriftBackend.execute_command(operation=%s, session_handle=%s)",
             operation,
-            session_handle,
+            thrift_handle,
         )
 
         spark_arrow_types = ttypes.TSparkArrowTypes(

src/databricks/sql/client.py

@@ -250,18 +250,6 @@ def read(self) -> Optional[OAuthToken]:
             + str(self.get_session_id_hex())
         )
 
-        # Create the session
-        self.session = Session(
-            server_hostname,
-            http_path,
-            http_headers,
-            session_configuration,
-            catalog,
-            schema,
-            _use_arrow_native_complex_types,
-            **kwargs
-        )
-
         self.use_inline_params = self._set_use_inline_params_with_warning(
             kwargs.get("use_inline_params", False)
         )

src/databricks/sql/session.py

@@ -84,16 +84,18 @@ def __init__(
             **kwargs,
         )
 
+    def open(self):
         self._session_id = self.backend.open_session(
-            session_configuration=session_configuration, catalog=catalog, schema=schema
+            session_configuration=self.session_configuration,
+            catalog=self.catalog,
+            schema=self.schema,
         )
-
         self.protocol_version = self.get_protocol_version(self._session_id)
-        self.open = True
+        self.is_open = True
         logger.info("Successfully opened session " + str(self.get_id_hex()))
 
     @staticmethod
-    def get_protocol_version(sessionId: SessionId):
+    def get_protocol_version(session_id: SessionId):
         """
         Since the sessionHandle will sometimes have a serverProtocolVersion, it takes
         precedence over the serverProtocolVersion defined in the OpenSessionResponse.