diff --git a/modin/pandas/base.py b/modin/pandas/base.py index 12e972e9480..c0128ba2c69 100644 --- a/modin/pandas/base.py +++ b/modin/pandas/base.py @@ -656,11 +656,6 @@ def aggregate(self, func=None, axis=0, *args, **kwargs): # noqa: PR01, RT01, D2 """ axis = self._get_axis_number(axis) - # if func is None, will switch to user-provided "named aggregation" kwargs - # if func is None: - # func = dict(kwargs.items()) - # kwargs = {} - result = None if axis == 0: diff --git a/modin/pandas/groupby.py b/modin/pandas/groupby.py index 925cd13319f..176a7e84174 100644 --- a/modin/pandas/groupby.py +++ b/modin/pandas/groupby.py @@ -1924,9 +1924,10 @@ def nsmallest(self, n=5, keep="first"): ) ) - def validate_func_kwargs(self, kwargs: dict): + def _validate_func_kwargs(self, kwargs: dict): """ - Validates types of user-provided "named aggregation" kwargs. + Validate types of user-provided "named aggregation" kwargs. + `TypeError` is raised if aggfunc is not `str` or callable. Parameters @@ -1965,7 +1966,7 @@ def aggregate(self, func=None, *args, engine=None, engine_kwargs=None, **kwargs) engine_default = engine is None and engine_kwargs is None # if func is None, will switch to user-provided "named aggregation" kwargs if func_is_none := func is None: - columns, func = self.validate_func_kwargs(kwargs) + columns, func = self._validate_func_kwargs(kwargs) kwargs = {} if isinstance(func, dict) and engine_default: raise SpecificationError("nested renamer is not supported")