Skip to content

Commit f0dea6c

Browse files
Jessesaishreeeee
authored andcommitted
Enable cloud fetch by default (#258)
Signed-off-by: Jesse Whitehouse <jesse.whitehouse@databricks.com> Signed-off-by: Sai Shree Pradhan <saishree.pradhan@databricks.com>
1 parent d799418 commit f0dea6c

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
- Other: Introduce SQLAlchemy dialect compliance test suite and enumerate all excluded tests
66
- Add integration tests for Databricks UC Volumes ingestion queries
77
- Add `_retry_max_redirects` config
8+
- Enable cloud fetch by default. To disable, set `use_cloud_fetch=False` when building `databricks.sql.client`.
89

910
## 2.9.3 (2023-08-24)
1011

src/databricks/sql/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ def read(self) -> Optional[OAuthToken]:
199199
self._session_handle = self.thrift_backend.open_session(
200200
session_configuration, catalog, schema
201201
)
202-
self.use_cloud_fetch = kwargs.get("use_cloud_fetch", False)
202+
self.use_cloud_fetch = kwargs.get("use_cloud_fetch", True)
203203
self.open = True
204204
logger.info("Successfully opened session " + str(self.get_session_id_hex()))
205205
self._cursors = [] # type: List[Cursor]

src/databricks/sql/thrift_backend.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -826,7 +826,7 @@ def execute_command(
826826
max_bytes,
827827
lz4_compression,
828828
cursor,
829-
use_cloud_fetch=False,
829+
use_cloud_fetch=True,
830830
parameters=[],
831831
):
832832
assert session_handle is not None

0 commit comments

Comments
 (0)