Skip to content

Commit

Permalink
more style changes
Browse files Browse the repository at this point in the history
  • Loading branch information
@christinafan
christinafan committed Jun 26, 2023
1 parent dfa7905 commit 429c309
Showing 1 changed file with 21 additions and 21 deletions.
42 changes: 21 additions & 21 deletions modin/core/storage_formats/pandas/query_compiler.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1389,7 +1389,7 @@ def window_mean(self, axis, window_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*window_args).mean(*args, **kwargs)
axis, window, lambda df: df.rolling(*window_args).mean(*args, **kwargs)
)
)
else:
Expand All @@ -1407,7 +1407,7 @@ def window_sum(self, axis, window_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*window_args).sum(*args, **kwargs)
axis, window, lambda df: df.rolling(*window_args).sum(*args, **kwargs)
)
)
else:
Expand All @@ -1425,7 +1425,7 @@ def window_var(self, axis, window_args, ddof, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*window_args).var(ddof=ddof, *args, **kwargs)
axis, window, lambda df: df.rolling(*window_args).var(ddof=ddof, *args, **kwargs)
)
)
else:
Expand All @@ -1443,7 +1443,7 @@ def window_std(self, axis, window_args, ddof, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*window_args).std(ddof=ddof, *args, **kwargs)
axis, window, lambda df: df.rolling(*window_args).std(ddof=ddof, *args, **kwargs)
)
)
else:
Expand All @@ -1459,7 +1459,7 @@ def rolling_count(self, axis, rolling_args):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).count()
axis, window, lambda df: df.rolling(*rolling_args).count()
)
)
else:
Expand All @@ -1477,7 +1477,7 @@ def rolling_sum(self, axis, rolling_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).sum(*args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).sum(*args, **kwargs)
)
)
else:
Expand All @@ -1495,7 +1495,7 @@ def rolling_sem(self, axis, rolling_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).sum(*args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).sum(*args, **kwargs)
)
)
else:
Expand All @@ -1513,7 +1513,7 @@ def rolling_mean(self, axis, rolling_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).mean(*args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).mean(*args, **kwargs)
)
)
else:
Expand All @@ -1531,7 +1531,7 @@ def rolling_median(self, axis, rolling_args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).median(**kwargs)
axis, window, lambda df: df.rolling(*rolling_args).median(**kwargs)
)
)
else:
Expand All @@ -1549,7 +1549,7 @@ def rolling_var(self, axis, rolling_args, ddof, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).var(ddof=ddof, *args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).var(ddof=ddof, *args, **kwargs)
)
)
else:
Expand All @@ -1567,7 +1567,7 @@ def rolling_std(self, axis, rolling_args, ddof, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).var(ddof=ddof, *args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).var(ddof=ddof, *args, **kwargs)
)
)
else:
Expand All @@ -1585,7 +1585,7 @@ def rolling_min(self, axis, rolling_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).min(*args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).min(*args, **kwargs)
)
)
else:
Expand All @@ -1603,7 +1603,7 @@ def rolling_max(self, axis, rolling_args, *args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).max(*args, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).max(*args, **kwargs)
)
)
else:
Expand All @@ -1621,7 +1621,7 @@ def rolling_skew(self, axis, rolling_args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).skew(**kwargs)
axis, window, lambda df: df.rolling(*rolling_args).skew(**kwargs)
)
)
else:
Expand All @@ -1639,7 +1639,7 @@ def rolling_kurt(self, axis, rolling_args, **kwargs):
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).kurt(**kwargs)
axis, window, lambda df: df.rolling(*rolling_args).kurt(**kwargs)
)
)
else:
Expand All @@ -1665,7 +1665,7 @@ def rolling_apply(self, axis, rolling_args, func, raw, engine, engine_kwargs, ar
return self.__constructor__(
self._modin_frame.window(
axis, window,
lambda df :
lambda df:
df.rolling(*rolling_args).apply(
func=func,
raw=raw,
Expand Down Expand Up @@ -1708,7 +1708,7 @@ def rolling_rank(self, axis, rolling_args, method, ascending, pct, numeric_only,
return self.__constructor__(
self._modin_frame.window(
axis, window,
lambda df : df.rolling(*rolling_args).rank(
lambda df: df.rolling(*rolling_args).rank(
method=method,
ascending=ascending,
pct=pct,
Expand All @@ -1734,7 +1734,7 @@ def rolling_quantile(self, axis, rolling_args, quantile, interpolation, **kwargs
if not center and isinstance(window, int):
return self.__constructor__(
self._modin_frame.window(
axis, window, lambda df : df.rolling(*rolling_args).quantile(quantile=quantile, interpolation=interpolation, **kwargs)
axis, window, lambda df: df.rolling(*rolling_args).quantile(quantile=quantile, interpolation=interpolation, **kwargs)
)
)
else:
Expand Down Expand Up @@ -1762,7 +1762,7 @@ def rolling_corr(self, axis, rolling_args, other, pairwise, *args, **kwargs):
return self.__constructor__(
self._modin_frame.window(
axis, window,
lambda df : df.rolling(*rolling_args).corr(
lambda df: df.rolling(*rolling_args).corr(
other=other, pairwise=pairwise, *args, **kwargs
)
)
Expand Down Expand Up @@ -1792,7 +1792,7 @@ def rolling_cov(self, axis, rolling_args, other, pairwise, ddof, **kwargs):
return self.__constructor__(
self._modin_frame.window(
axis, window,
lambda df : df.rolling(*rolling_args).cov(
lambda df: df.rolling(*rolling_args).cov(
other=other, pairwise=pairwise, **kwargs
)
)
Expand All @@ -1807,7 +1807,7 @@ def rolling_aggregate(self, axis, rolling_args, func, *args, **kwargs):
return self.__constructor__(
self._modin_frame.window(
axis, window,
lambda df : df.rolling(*rolling_args).aggregate(func=func, *args, **kwargs)
lambda df: df.rolling(*rolling_args).aggregate(func=func, *args, **kwargs)
)
)
else:
Expand Down

0 comments on commit 429c309

Please sign in to comment.