Merge remote-tracking branch 'origin/main' into SNOW-3309660-fix-xml-tests-for-snowfort

Author: sfc-gh-mayliu

.github/workflows/daily_precommit.yml

@@ -198,6 +198,8 @@ jobs:
           cloud_provider: ${{ matrix.cloud-provider }}
           PYTEST_ADDOPTS: --color=yes --tb=short
           TOX_PARALLEL_NO_SPINNER: 1
+          SNOWPARK_PYTHON_API_TEST_BUCKET_PATH: ${{ secrets.SNOWPARK_PYTHON_API_TEST_BUCKET_PATH }}
+          SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION: ${{ vars.SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION }}
         shell: bash
       - name: Install MS ODBC Driver (Ubuntu only)
         if: ${{ matrix.os.download_name == 'linux' }}
@@ -611,7 +613,8 @@ jobs:
         run: uv pip install -U setuptools pip wheel --system
       - name: Install tox
         run: uv pip install tox --system
-      - if: ${{ contains('macos', matrix.os.download_name) }}
+      # TODO: enable doctest for 3.14
+      - if: ${{ contains('macos', matrix.os.download_name) && matrix.python-version != '3.14' }}
         name: Run doctests
         run: python -m tox -e "py${PYTHON_VERSION}-doctest-notudf-ci"
         env:
@@ -620,7 +623,9 @@ jobs:
           PYTEST_ADDOPTS: --color=yes --tb=short --disable_cte_optimization
           TOX_PARALLEL_NO_SPINNER: 1
         shell: bash
-      - name: Run tests (excluding doctests)
+      # TODO: enable for 3.14
+      - if: ${{ matrix.python-version != '3.14' }}
+        name: Run tests (excluding doctests)
         run: python -m tox -e "py${PYTHON_VERSION/\./}-dailynotdoctest-ci"
         env:
           PYTHON_VERSION: ${{ matrix.python-version }}
@@ -630,6 +635,18 @@ jobs:
           SNOWPARK_PYTHON_API_TEST_BUCKET_PATH: ${{ secrets.SNOWPARK_PYTHON_API_TEST_BUCKET_PATH }}
           SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION: ${{ vars.SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION }}
         shell: bash
+      # TODO: remove the test below and run udf tests for 3.14
+      - if: ${{ matrix.python-version == '3.14' }}
+        name: Run tests (excluding udf, doctests)
+        run: python -m tox -e "py${PYTHON_VERSION/\./}-dailynotdoctestnotudf-ci"
+        env:
+          PYTHON_VERSION: ${{ matrix.python-version }}
+          cloud_provider: ${{ matrix.cloud-provider }}
+          PYTEST_ADDOPTS: --color=yes --tb=short --disable_cte_optimization
+          TOX_PARALLEL_NO_SPINNER: 1
+          SNOWPARK_PYTHON_API_TEST_BUCKET_PATH: ${{ secrets.SNOWPARK_PYTHON_API_TEST_BUCKET_PATH }}
+          SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION: ${{ vars.SNOWPARK_PYTHON_API_S3_STORAGE_INTEGRATION }}
+        shell: bash
       - name: Combine coverages
         run: python -m tox -e coverage --skip-missing-interpreters false
         shell: bash

CHANGELOG.md

@@ -1,6 +1,6 @@
 # Release History
 
-## 1.50.0 (TBD)
+## 1.50.0 (2026-04-23)
 
 ### Snowpark Python API Updates
 

recipe/meta.yaml

@@ -1,5 +1,5 @@
 {% set name = "snowflake-snowpark-python" %}
-{% set version = "1.49.0" %}
+{% set version = "1.50.0" %}
 {% set noarch_build = (os.environ.get('SNOWFLAKE_SNOWPARK_PYTHON_NOARCH_BUILD', 'false')) == 'true' %}
 {% set build_number = os.environ.get('SNOWFLAKE_SNOWPARK_PYTHON_BUILD_NUMBER', 0) %}
 

src/snowflake/snowpark/_internal/analyzer/select_statement.py

@@ -1604,7 +1604,17 @@ def filter(self, col: Expression) -> "SelectStatement":
         can_be_flattened = (
             (not self.flatten_disabled)
             and can_clause_dependent_columns_flatten(
-                derive_dependent_columns(col), self.column_states, "filter"
+                derive_dependent_columns(col),
+                self.column_states,
+                "filter",
+                # In Snowpark Connect compatible mode, the NEW-column branch
+                # below allows flattening through any subquery. Pass
+                # subquery_has_limit so that branch can still reject
+                # flattening across LIMIT/OFFSET, since WHERE cannot cross
+                # LIMIT/OFFSET without changing semantics.
+                subquery_has_limit_or_offset=(
+                    self.limit_ is not None or self.offset is not None
+                ),
             )
             and not has_data_generator_or_window_function_exp(self.projection)
             and not (
@@ -2175,6 +2185,7 @@ def can_clause_dependent_columns_flatten(
     dependent_columns: Optional[AbstractSet[str]],
     subquery_column_states: ColumnStateDict,
     clause: Literal["filter", "sort"],
+    subquery_has_limit_or_offset: bool = False,
 ) -> bool:
     assert clause in (
         "filter",
@@ -2218,6 +2229,14 @@ def can_clause_dependent_columns_flatten(
                         and context._snowpark_connect_flatten_select_after_sort
                     ):
                         return False
+                    # Compatible-mode safety: even though we loosened the
+                    # NEW-column flatten rule above, we must not flatten a
+                    # WHERE across LIMIT/OFFSET on a NEW column — that
+                    # would push the filter in front of the limit and
+                    # change the result set. (Sort has its own
+                    # `not self.limit_` guard at the call site.)
+                    if clause == "filter" and subquery_has_limit_or_offset:
+                        return False
 
     return True
 

src/snowflake/snowpark/_internal/type_utils.py

@@ -280,7 +280,8 @@ def convert_sf_to_sp_type(
         if internal_size > 0:
             return StringType(
                 internal_size,
-                internal_size == max_string_size or internal_size == _MAX_ICEBERG_STRING_SIZE,
+                internal_size == max_string_size
+                or internal_size == _MAX_ICEBERG_STRING_SIZE,
             )
         elif internal_size == 0:
             return StringType()

src/snowflake/snowpark/version.py

@@ -2,4 +2,4 @@
 
 
 # Update this for the versions
-VERSION = (1, 49, 0)
+VERSION = (1, 50, 0)

tests/ast/data/DataFrame.agg.test

@@ -508,6 +508,6 @@ client_language {
 }
 client_version {
   major: 1
-  minor: 49
+  minor: 50
 }
 id: "\003U\"\366q\366P\346\260\261?\234\303\254\316\353"

tests/ast/data/DataFrame.ai.test

@@ -2146,6 +2146,6 @@ client_language {
 }
 client_version {
   major: 1
-  minor: 49
+  minor: 50
 }
 id: "\003U\"\366q\366P\346\260\261?\234\303\254\316\353"

tests/ast/data/DataFrame.col_ilike.test

@@ -239,6 +239,6 @@ client_language {
 }
 client_version {
   major: 1
-  minor: 49
+  minor: 50
 }
 id: "\003U\"\366q\366P\346\260\261?\234\303\254\316\353"

tests/ast/data/DataFrame.collect.test

@@ -511,6 +511,6 @@ client_language {
 }
 client_version {
   major: 1
-  minor: 49
+  minor: 50
 }
 id: "\003U\"\366q\366P\346\260\261?\234\303\254\316\353"