Skip to content

Commit

Permalink
Revert "[PECO-1083] Updated thrift files and added check for protocol…
Browse files Browse the repository at this point in the history
… version (#229)"

This reverts commit 241e934.
  • Loading branch information
Jesse authored Oct 1, 2023
1 parent e064e25 commit d44e2a7
Show file tree
Hide file tree
Showing 3 changed files with 324 additions and 3,964 deletions.
13 changes: 0 additions & 13 deletions src/databricks/sql/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import requests
import json
import os
from databricks.sql.thrift_api.TCLIService import ttypes

from databricks.sql import __version__
from databricks.sql import *
Expand Down Expand Up @@ -226,11 +225,6 @@ def __del__(self):
def get_session_id(self):
return self.thrift_backend.handle_to_id(self._session_handle)

def get_session_protocol_version(self):
return self.thrift_backend.extract_protocol_version_from_handle(
self._session_handle
)

def get_session_id_hex(self):
return self.thrift_backend.handle_to_hex_id(self._session_handle)

Expand Down Expand Up @@ -507,13 +501,6 @@ def execute(
"""
if parameters is None:
parameters = []
elif (
self.connection.get_session_protocol_version()
< ttypes.TProtocolVersion.SPARK_CLI_SERVICE_PROTOCOL_V8
):
raise Error(
"Parameterized operations are not supported by this server. DBR 14.1 is required."
)
else:
parameters = named_parameters_to_tsparkparams(parameters)

Expand Down
Loading

0 comments on commit d44e2a7

Please sign in to comment.