Skip to content

Commit 52691c7

Browse files
dcherianclaude
andcommitted
refactor: extract dask-specific functions to dask.py
Create new modules that re-export dask/cubed functions from core.py: - flox/dask.py: dask_groupby_agg, dask_groupby_scan, etc. - flox/cubed.py: cubed_groupby_agg This improves code organization and provides a clearer API for backend-specific functionality. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]>
1 parent 16d2fec commit 52691c7

File tree

2 files changed

+48
-0
lines changed

2 files changed

+48
-0
lines changed

flox/cubed.py

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
"""Cubed-specific functions for groupby operations.
2+
3+
This module provides Cubed-specific implementations for groupby operations.
4+
Re-exported from flox.core for backward compatibility.
5+
"""
6+
7+
from __future__ import annotations
8+
9+
# Re-export from core for backward compatibility
10+
from .core import (
11+
cubed_groupby_agg,
12+
)
13+
14+
__all__ = [
15+
"cubed_groupby_agg",
16+
]

flox/dask.py

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
"""Dask-specific functions for groupby operations.
2+
3+
This module provides Dask-specific implementations for groupby operations.
4+
Re-exported from flox.core for backward compatibility.
5+
"""
6+
7+
from __future__ import annotations
8+
9+
# Re-export from core for backward compatibility
10+
from .core import (
11+
_collapse_blocks_along_axes,
12+
_extract_unknown_groups,
13+
_grouped_combine,
14+
_normalize_indexes,
15+
_simple_combine,
16+
_unify_chunks,
17+
dask_groupby_agg,
18+
dask_groupby_scan,
19+
subset_to_blocks,
20+
)
21+
22+
__all__ = [
23+
"_collapse_blocks_along_axes",
24+
"_extract_unknown_groups",
25+
"_grouped_combine",
26+
"_normalize_indexes",
27+
"_simple_combine",
28+
"_unify_chunks",
29+
"dask_groupby_agg",
30+
"dask_groupby_scan",
31+
"subset_to_blocks",
32+
]

0 commit comments

Comments
 (0)