Skip to content

Commit f76d740

Browse files
remove excess changes
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent 8aa4649 commit f76d740

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

src/databricks/sql/backend/thrift_backend.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,6 @@ def __init__(
149149
http_path,
150150
)
151151

152-
super().__init__(ssl_options, **kwargs)
153-
154152
port = port or 443
155153
if kwargs.get("_connection_uri"):
156154
uri = kwargs.get("_connection_uri")
@@ -174,6 +172,10 @@ def __init__(
174172
)
175173

176174
# Cloud fetch
175+
self._max_download_threads = kwargs.get("max_download_threads", 10)
176+
177+
self._ssl_options = ssl_options
178+
177179
self._auth_provider = auth_provider
178180

179181
# Connector version 3 retry approach

src/databricks/sql/utils.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -247,9 +247,6 @@ def __init__(
247247
ssl_options=ssl_options,
248248
)
249249

250-
# Initialize download manager
251-
self.download_manager: Optional["ResultFileDownloadManager"] = None
252-
253250
def next_n_rows(self, num_rows: int) -> "pyarrow.Table":
254251
"""
255252
Get up to the next n rows of the cloud fetch Arrow dataframes.

0 commit comments

Comments
 (0)