We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b2202c7 commit 8e759dbCopy full SHA for 8e759db
src/databricks/sql/thrift_backend.py
@@ -156,8 +156,6 @@ def __init__(
156
)
157
158
# Cloud fetch
159
- self._use_cloud_fetch = kwargs.get("use_cloud_fetch", True)
160
-
161
self.max_download_threads = kwargs.get("max_download_threads", 10)
162
163
self._ssl_options = ssl_options
@@ -900,6 +898,8 @@ def execute_command(
900
898
):
901
899
assert session_handle is not None
902
+ self._use_cloud_fetch = use_cloud_fetch
+
903
spark_arrow_types = ttypes.TSparkArrowTypes(
904
timestampAsArrow=self._use_arrow_native_timestamps,
905
decimalAsArrow=self._use_arrow_native_decimals,
0 commit comments