Skip to content

Commit 890889c

Browse files
Disabling multiline queries by default (#3436)
1 parent 41a1b90 commit 890889c

File tree

4 files changed

+21
-1
lines changed

4 files changed

+21
-1
lines changed

src/snowflake/snowpark/session.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -659,11 +659,13 @@ def __init__(
659659
)
660660
self._generate_multiline_queries: bool = (
661661
self._conn._get_client_side_session_parameter(
662-
_PYTHON_SNOWPARK_GENERATE_MULTILINE_QUERIES, True
662+
_PYTHON_SNOWPARK_GENERATE_MULTILINE_QUERIES, False
663663
)
664664
)
665665
if self._generate_multiline_queries:
666666
self._enable_multiline_queries()
667+
else:
668+
self._disable_multiline_queries()
667669

668670
self._large_query_breakdown_enabled: bool = self.is_feature_enabled_for_version(
669671
_PYTHON_SNOWPARK_USE_LARGE_QUERY_BREAKDOWN_OPTIMIZATION_VERSION
@@ -788,12 +790,14 @@ def __str__(self):
788790
def _enable_multiline_queries(self):
789791
import snowflake.snowpark._internal.analyzer.analyzer_utils as analyzer_utils
790792

793+
self._generate_multiline_queries = True
791794
analyzer_utils.NEW_LINE = "\n"
792795
analyzer_utils.TAB = " "
793796

794797
def _disable_multiline_queries(self):
795798
import snowflake.snowpark._internal.analyzer.analyzer_utils as analyzer_utils
796799

800+
self._generate_multiline_queries = False
797801
analyzer_utils.NEW_LINE = ""
798802
analyzer_utils.TAB = ""
799803

tests/integ/conftest.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,8 @@ def session(
278278
session._cte_optimization_enabled = cte_optimization_enabled
279279
session._join_alias_fix = join_alias_fix
280280
session.ast_enabled = ast_enabled
281+
if not session._generate_multiline_queries:
282+
session._enable_multiline_queries()
281283

282284
if (RUNNING_ON_GH or RUNNING_ON_JENKINS) and not local_testing_mode:
283285
set_up_external_access_integration_resources(

tests/unit/conftest.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,4 +81,5 @@ def mock_session(mock_analyzer) -> Session:
8181
fake_session._analyzer = mock_analyzer
8282
fake_session._plan_lock = mock.MagicMock()
8383
mock_analyzer.session = fake_session
84+
fake_session._enable_multiline_queries()
8485
return fake_session

tests/unit/test_analyzer_util_suite.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,19 @@
4242
)
4343
from snowflake.snowpark._internal.utils import EMPTY_STRING
4444

45+
import snowflake.snowpark._internal.analyzer.analyzer_utils as analyzer_utils
46+
47+
48+
@pytest.fixture(autouse=True)
49+
def setup():
50+
original_new_line = analyzer_utils.NEW_LINE
51+
original_tab = analyzer_utils.TAB
52+
analyzer_utils.NEW_LINE = "\n"
53+
analyzer_utils.TAB = " "
54+
yield
55+
analyzer_utils.NEW_LINE = original_new_line
56+
analyzer_utils.TAB = original_tab
57+
4558

4659
def test_generate_scoped_temp_objects():
4760
temp_file_format_name = "SNOWPARK_TEMP_FILE_FORMAT_E0ZW8Z9WMY"

0 commit comments

Comments
 (0)