Skip to content

Commit 510b0a3

Browse files
make SEA Http Client instance a private member
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent f7fd1d9 commit 510b0a3

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

src/databricks/sql/backend/sea/backend.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ def __init__(
134134
self.warehouse_id = self._extract_warehouse_id(http_path)
135135

136136
# Initialize HTTP client
137-
self.http_client = SeaHttpClient(
137+
self._http_client = SeaHttpClient(
138138
server_hostname=server_hostname,
139139
port=port,
140140
http_path=http_path,
@@ -226,7 +226,7 @@ def open_session(
226226
schema=schema,
227227
)
228228

229-
response = self.http_client._make_request(
229+
response = self._http_client._make_request(
230230
method="POST", path=self.SESSION_PATH, data=request_data.to_dict()
231231
)
232232

@@ -266,7 +266,7 @@ def close_session(self, session_id: SessionId) -> None:
266266
session_id=sea_session_id,
267267
)
268268

269-
self.http_client._make_request(
269+
self._http_client._make_request(
270270
method="DELETE",
271271
path=self.SESSION_PATH_WITH_ID.format(sea_session_id),
272272
data=request_data.to_dict(),
@@ -477,7 +477,7 @@ def execute_command(
477477
result_compression=result_compression,
478478
)
479479

480-
response_data = self.http_client._make_request(
480+
response_data = self._http_client._make_request(
481481
method="POST", path=self.STATEMENT_PATH, data=request.to_dict()
482482
)
483483
response = ExecuteStatementResponse.from_dict(response_data)
@@ -522,7 +522,7 @@ def cancel_command(self, command_id: CommandId) -> None:
522522
raise ValueError("Not a valid SEA command ID")
523523

524524
request = CancelStatementRequest(statement_id=sea_statement_id)
525-
self.http_client._make_request(
525+
self._http_client._make_request(
526526
method="POST",
527527
path=self.CANCEL_STATEMENT_PATH_WITH_ID.format(sea_statement_id),
528528
data=request.to_dict(),
@@ -547,7 +547,7 @@ def close_command(self, command_id: CommandId) -> None:
547547
raise ValueError("Not a valid SEA command ID")
548548

549549
request = CloseStatementRequest(statement_id=sea_statement_id)
550-
self.http_client._make_request(
550+
self._http_client._make_request(
551551
method="DELETE",
552552
path=self.STATEMENT_PATH_WITH_ID.format(sea_statement_id),
553553
data=request.to_dict(),
@@ -575,7 +575,7 @@ def get_query_state(self, command_id: CommandId) -> CommandState:
575575
raise ValueError("Not a valid SEA command ID")
576576

577577
request = GetStatementRequest(statement_id=sea_statement_id)
578-
response_data = self.http_client._make_request(
578+
response_data = self._http_client._make_request(
579579
method="GET",
580580
path=self.STATEMENT_PATH_WITH_ID.format(sea_statement_id),
581581
data=request.to_dict(),
@@ -615,7 +615,7 @@ def get_execution_result(
615615
request = GetStatementRequest(statement_id=sea_statement_id)
616616

617617
# Get the statement result
618-
response_data = self.http_client._make_request(
618+
response_data = self._http_client._make_request(
619619
method="GET",
620620
path=self.STATEMENT_PATH_WITH_ID.format(sea_statement_id),
621621
data=request.to_dict(),
@@ -647,7 +647,7 @@ def get_chunk_link(self, statement_id: str, chunk_index: int) -> ExternalLink:
647647
ExternalLink: External link for the chunk
648648
"""
649649

650-
response_data = self.http_client._make_request(
650+
response_data = self._http_client._make_request(
651651
method="GET",
652652
path=self.CHUNK_PATH_WITH_ID_AND_INDEX.format(statement_id, chunk_index),
653653
)

0 commit comments

Comments
 (0)