Skip to content

Commit 874a3c7

Browse files
address comments
1 parent 516fa67 commit 874a3c7

File tree

2 files changed

+15
-21
lines changed

2 files changed

+15
-21
lines changed

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

Lines changed: 12 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -9112,15 +9112,13 @@ def cumsum(
91129112
relaxed_query_compiler = None
91139113
if self._relaxed_query_compiler is not None:
91149114
relaxed_query_compiler = self._relaxed_query_compiler._cumsum_internal(
9115-
# axis=axis,
9116-
# skipna=skipna,
9117-
*args,
9115+
axis=axis,
9116+
skipna=skipna,
91189117
**kwargs,
91199118
)
91209119
qc = self._cumsum_internal(
9121-
# axis=axis,
9122-
# skipna=skipna,
9123-
*args,
9120+
axis=axis,
9121+
skipna=skipna,
91249122
**kwargs,
91259123
)
91269124
return self._maybe_set_relaxed_qc(qc, relaxed_query_compiler)
@@ -9172,15 +9170,13 @@ def cummin(
91729170
relaxed_query_compiler = None
91739171
if self._relaxed_query_compiler is not None:
91749172
relaxed_query_compiler = self._relaxed_query_compiler._cummin_internal(
9175-
# axis=axis,
9176-
# skipna=skipna,
9177-
*args,
9173+
axis=axis,
9174+
skipna=skipna,
91789175
**kwargs,
91799176
)
91809177
qc = self._cummin_internal(
9181-
# axis=axis,
9182-
# skipna=skipna,
9183-
*args,
9178+
axis=axis,
9179+
skipna=skipna,
91849180
**kwargs,
91859181
)
91869182
return self._maybe_set_relaxed_qc(qc, relaxed_query_compiler)
@@ -9232,15 +9228,13 @@ def cummax(
92329228
relaxed_query_compiler = None
92339229
if self._relaxed_query_compiler is not None:
92349230
relaxed_query_compiler = self._relaxed_query_compiler._cummax_internal(
9235-
# axis=axis,
9236-
# skipna=skipna,
9237-
*args,
9231+
axis=axis,
9232+
skipna=skipna,
92389233
**kwargs,
92399234
)
92409235
qc = self._cummax_internal(
9241-
# axis=axis,
9242-
# skipna=skipna,
9243-
*args,
9236+
axis=axis,
9237+
skipna=skipna,
92449238
**kwargs,
92459239
)
92469240
return self._maybe_set_relaxed_qc(qc, relaxed_query_compiler)

tests/integ/modin/test_faster_pandas.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -354,7 +354,7 @@ def test_cumulative_functions(session, func):
354354

355355
# create snow dataframes
356356
df = pd.read_snowflake(table_name)
357-
snow_result = df[getattr(df["B"], func)() > 0]
357+
snow_result = getattr(df["B"], func)()
358358

359359
# verify that the input dataframe has a populated relaxed query compiler
360360
assert df._query_compiler._relaxed_query_compiler is not None
@@ -368,10 +368,10 @@ def test_cumulative_functions(session, func):
368368

369369
# create pandas dataframes
370370
native_df = df.to_pandas()
371-
native_result = native_df[getattr(native_df["B"], func)() > 0]
371+
native_result = getattr(native_df["B"], func)()
372372

373373
# compare results
374-
assert_frame_equal(snow_result, native_result)
374+
assert_series_equal(snow_result, native_result)
375375

376376

377377
@sql_count_checker(query_count=3)

0 commit comments

Comments
 (0)