Skip to content

Commit a0318e3

Browse files
committed
databricks client type
Signed-off-by: Sai Shree Pradhan <saishree.pradhan@databricks.com>
1 parent 5345384 commit a0318e3

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/databricks/sql/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ def read(self) -> Optional[OAuthToken]:
280280

281281
driver_connection_params = DriverConnectionParameters(
282282
http_path=http_path,
283-
mode=DatabricksClientType.THRIFT,
283+
mode=DatabricksClientType.SEA if self.session.use_sea else DatabricksClientType.THRIFT,
284284
host_info=HostDetails(host_url=server_hostname, port=self.session.port),
285285
auth_mech=TelemetryHelper.get_auth_mechanism(self.session.auth_provider),
286286
auth_flow=TelemetryHelper.get_auth_flow(self.session.auth_provider),

src/databricks/sql/session.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,10 +97,10 @@ def _create_backend(
9797
kwargs: dict,
9898
) -> DatabricksClient:
9999
"""Create and return the appropriate backend client."""
100-
use_sea = kwargs.get("use_sea", False)
100+
self.use_sea = kwargs.get("use_sea", False)
101101

102102
databricks_client_class: Type[DatabricksClient]
103-
if use_sea:
103+
if self.use_sea:
104104
logger.debug("Creating SEA backend client")
105105
databricks_client_class = SeaDatabricksClient
106106
else:

0 commit comments

Comments
 (0)