Merge branch 'main' into helmeleegy-SNOW-1620315

Author: sfc-gh-helmeleegy

setup.py

@@ -209,7 +209,7 @@ def run(self):
             "plotly<6.0.0",  # Snowpark pandas 3rd party library testing
             # TODO(SNOW-1938831): Test snowflake-ml-python on python 3.12 once
             # snowflake-ml-python is available on python 3.12.
-            "snowflake-ml-python; python_version<'3.12'",
+            "snowflake-ml-python>=1.8.0; python_version<'3.12'",
         ],
         "localtest": [
             "pandas",

src/snowflake/snowpark/_internal/telemetry.py

@@ -125,7 +125,6 @@ class TelemetryField(Enum):
     "select_expr": 1,
     "drop": 1,
     "agg": 2,
-    "distinct": 2,
     "with_column": 1,
     "with_columns": 1,
     "with_column_renamed": 1,

src/snowflake/snowpark/dataframe.py

@@ -2397,14 +2397,20 @@ def distinct(
                 resource_usage=resource_usage_collector.get_resource_usage(),
             )
         else:
-            df = self.group_by(
-                [
-                    self.col(quote_name(f.name), _emit_ast=False)
-                    for f in self.schema.fields
-                ],
-                _emit_ast=False,
-            ).agg(_emit_ast=False)
-            adjust_api_subcalls(df, "DataFrame.distinct[group_by]", len_subcalls=2)
+            with ResourceUsageCollector() as resource_usage_collector:
+                df = self.group_by(
+                    [
+                        self.col(quote_name(f.name), _emit_ast=False)
+                        for f in self.schema.fields
+                    ],
+                    _emit_ast=False,
+                ).agg(_emit_ast=False)
+            adjust_api_subcalls(
+                df,
+                "DataFrame.distinct[group_by]",
+                len_subcalls=2,
+                resource_usage=resource_usage_collector.get_resource_usage(),
+            )
 
         if _emit_ast:
             df._ast_id = stmt.uid

src/snowflake/snowpark/modin/plugin/compiler/snowflake_query_compiler.py

@@ -19259,7 +19259,6 @@ def unstack(
         self._raise_not_implemented_error_for_timedelta()
 
         level = [level]
-
         index_names = self.get_index_names()
 
         # Check to see if we have a MultiIndex, if we do, make sure we remove

src/snowflake/snowpark/modin/plugin/docstrings/series.py

@@ -3645,7 +3645,7 @@ def to_string():
         --------
         >>> ser = pd.Series([1, 2, 3]).to_string()
         >>> ser
-        '0    1\n1    2\n2    3'
+        '0    1\\n1    2\\n2    3'
         """
 
     def to_timestamp():