Merge branch 'main' into changelog-update-post-1.12.1-release

CHANGELOG.md

@@ -1,5 +1,18 @@
 # Release History
 
+## 1.13.0 (TBD)
+
+### New Features
+
+- Added support for an optional `date_part` argument in function `last_day`
+- `SessionBuilder.app_name` will set the query_tag after the session is created.
+
+### Bug Fixes
+
+- Fixed a bug in `DataFrame.to_local_iterator` where the iterator could yield wrong results if another query is executed before the iterator finishes due to wrong isolation level. For details, please see #945.
+- Fixed a bug that truncated table names in error messages while running a plan with local testing enabled.
+- Fixed a bug that `Session.range` returns empty result when the range is large.
+
 ## 1.12.1 (2024-02-08)
 
 ### Improvements
@@ -28,7 +41,9 @@
   - `sign`/`signum`
 - Added the following functions to `DataFrame.analytics`:
   - Added the `moving_agg` function in `DataFrame.analytics` to enable moving aggregations like sums and averages with multiple window sizes.
-  - Added the `cummulative_agg` function in `DataFrame.analytics` to enable moving aggregations like sums and averages with multiple window sizes.
+  - Added the `cummulative_agg` function in `DataFrame.analytics` to enable commulative aggregations like sums and averages on multiple columns.
+  - Added the `compute_lag` and `compute_lead` functions in `DataFrame.analytics` for enabling lead and lag calculations on multiple columns.
+  - Added the `time_series_agg` function in `DataFrame.analytics` to enable time series aggregations like sums and averages with multiple time windows.
 
 ### Bug Fixes
 

docs/source/_templates/autosummary/accessor_method.rst

@@ -0,0 +1,6 @@
+{{ fullname }}
+{{ underline }}
+
+.. currentmodule:: {{ module + "." + objname.split(".")[0] }}
+
+.. automethod:: {{ ".".join(objname.split(".")[1:]) }}

docs/source/session.rst

@@ -11,6 +11,19 @@ Snowpark Session
 
     Session
 
+
+.. rubric:: SessionBuilder
+
+.. autosummary::
+    :toctree: api/
+    :template: autosummary/accessor_method.rst
+
+    Session.SessionBuilder.app_name
+    Session.SessionBuilder.config
+    Session.SessionBuilder.configs
+    Session.SessionBuilder.create
+    Session.SessionBuilder.getOrCreate
+
 .. rubric:: Methods
 
 .. 

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

@@ -448,7 +448,7 @@ def sort_statement(order: List[str], child: str) -> str:
 def range_statement(start: int, end: int, step: int, column_name: str) -> str:
     range = end - start
 
-    if range * step < 0:
+    if (range > 0 > step) or (range < 0 < step):
         count = 0
     else:
         count = math.ceil(range / step)

src/snowflake/snowpark/_internal/server_connection.py

@@ -434,8 +434,16 @@ def _to_data_or_iter(
         results_cursor: SnowflakeCursor,
         to_pandas: bool = False,
         to_iter: bool = False,
-        num_statements: Optional[int] = None,
     ) -> Dict[str, Any]:
+        if (
+            to_iter and not to_pandas
+        ):  # Fix for SNOW-869536, to_pandas doesn't have this issue, SnowflakeCursor.fetch_pandas_batches already handles the isolation.
+            new_cursor = results_cursor.connection.cursor()
+            new_cursor.execute(
+                f"SELECT * FROM TABLE(RESULT_SCAN('{results_cursor.sfqid}'))"
+            )
+            results_cursor = new_cursor
+
         if to_pandas:
             try:
                 data_or_iter = (