Skip to content

Commit cad0e29

Browse files
mzeitlin11JulianWgs
authored andcommitted
REF: move masked dispatch inside _ea_wrap (pandas-dev#41347)
1 parent 7f57526 commit cad0e29

File tree

1 file changed

+15
-16
lines changed

1 file changed

+15
-16
lines changed

pandas/core/groupby/ops.py

+15-16
Original file line numberDiff line numberDiff line change
@@ -327,6 +327,14 @@ def _ea_wrap_cython_operation(
327327
re-wrap if appropriate.
328328
"""
329329
# TODO: general case implementation overridable by EAs.
330+
if isinstance(values, BaseMaskedArray) and self.uses_mask():
331+
return self._masked_ea_wrap_cython_operation(
332+
values,
333+
min_count=min_count,
334+
ngroups=ngroups,
335+
comp_ids=comp_ids,
336+
**kwargs,
337+
)
330338
orig_values = values
331339

332340
if isinstance(orig_values, (DatetimeArray, PeriodArray)):
@@ -614,22 +622,13 @@ def cython_operation(
614622

615623
if not isinstance(values, np.ndarray):
616624
# i.e. ExtensionArray
617-
if isinstance(values, BaseMaskedArray) and self.uses_mask():
618-
return self._masked_ea_wrap_cython_operation(
619-
values,
620-
min_count=min_count,
621-
ngroups=ngroups,
622-
comp_ids=comp_ids,
623-
**kwargs,
624-
)
625-
else:
626-
return self._ea_wrap_cython_operation(
627-
values,
628-
min_count=min_count,
629-
ngroups=ngroups,
630-
comp_ids=comp_ids,
631-
**kwargs,
632-
)
625+
return self._ea_wrap_cython_operation(
626+
values,
627+
min_count=min_count,
628+
ngroups=ngroups,
629+
comp_ids=comp_ids,
630+
**kwargs,
631+
)
633632

634633
return self._cython_op_ndim_compat(
635634
values,

0 commit comments

Comments
 (0)