Skip to content

Commit d67f60a

Browse files
committed
Set group names properly instead of renaming later
1 parent 2b36965 commit d67f60a

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

dask_groupby/xarray.py

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -217,9 +217,7 @@ def xarray_reduce(
217217
return result
218218

219219
axis = tuple(range(-len(dim), 0))
220-
221-
group_names = tuple(g.name for g in by)
222-
# ds = ds.drop_vars(tuple(g for g in group_names))
220+
group_names = tuple(g.name if not binned else f"{g.name}_bins" for g, binned in zip(by, isbin))
223221

224222
if len(by) > 1:
225223
group_idx, expected_groups, group_shape, _, _, _ = factorize_(
@@ -329,17 +327,12 @@ def wrapper(array, to_group, *, func, skipna, **kwargs):
329327
},
330328
)
331329

332-
renamer = {}
333330
for name, expect, isbin_ in zip(group_names, expected_groups, isbin):
334331
if isbin_:
335332
expect = [pd.Interval(left, right) for left, right in zip(expect[:-1], expect[1:])]
336333
if isinstance(actual, xr.Dataset) and name in actual:
337334
actual = actual.drop_vars(name)
338335
actual[name] = expect
339-
if isbin_:
340-
renamer[name] = f"{name}_bins"
341-
if renamer:
342-
actual = actual.rename(renamer)
343336

344337
# if grouping by multi-indexed variable, then restore it
345338
for name, index in ds.indexes.items():

0 commit comments

Comments
 (0)