Skip to content

Commit d580c03

Browse files
dcherianclaude
andcommitted
refactor: extract dask-specific functions to dask.py and helpers to lib.py
Move dask-specific functions to flox/dask.py: - dask_groupby_agg, dask_groupby_scan - _grouped_combine, _simple_combine (via import) - _unify_chunks, _normalize_indexes, subset_to_blocks - _extract_unknown_groups, _collapse_blocks_along_axes Move helper functions to flox/lib.py: - identity - _is_arg_reduction, _is_minmax_reduction, _is_first_last_reduction - _is_bool_supported_reduction, _is_sparse_supported_reduction - _is_reindex_sparse_supported_reduction 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]>
1 parent 35816af commit d580c03

File tree

5 files changed

+702
-773
lines changed

5 files changed

+702
-773
lines changed

flox/aggregate_sparse.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,8 @@
88
import numpy as np
99
import sparse
1010

11-
from flox.core import _factorize_multiple, _is_sparse_supported_reduction, factorize_
11+
from flox.core import _factorize_multiple, factorize_
12+
from flox.lib import _is_sparse_supported_reduction
1213
from flox.xrdtypes import INF, NINF, _get_fill_value
1314
from flox.xrutils import notnull
1415

0 commit comments

Comments
 (0)