|
3 | 3 |
|
4 | 4 | import xarray as xr
|
5 | 5 |
|
6 |
| -from . import parameterized, requires_dask |
| 6 | +from . import _skip_slow, parameterized, requires_dask |
7 | 7 |
|
8 | 8 |
|
9 | 9 | class GroupBy:
|
@@ -41,13 +41,23 @@ def setup(self, *args, **kwargs):
|
41 | 41 |
|
42 | 42 |
|
43 | 43 | class GroupByDataFrame(GroupBy):
|
| 44 | + """Run groupby tests using pandas DataFrame.""" |
| 45 | + |
44 | 46 | def setup(self, *args, **kwargs):
|
| 47 | + # Skip testing in CI as it won't ever change in a commit: |
| 48 | + _skip_slow() |
| 49 | + |
45 | 50 | super().setup(**kwargs)
|
46 | 51 | self.ds1d = self.ds1d.to_dataframe()
|
47 | 52 |
|
48 | 53 |
|
49 | 54 | class GroupByDaskDataFrame(GroupBy):
|
| 55 | + """Run groupby tests using dask DataFrame.""" |
| 56 | + |
50 | 57 | def setup(self, *args, **kwargs):
|
| 58 | + # Skip testing in CI as it won't ever change in a commit: |
| 59 | + _skip_slow() |
| 60 | + |
51 | 61 | requires_dask()
|
52 | 62 | super().setup(**kwargs)
|
53 | 63 | self.ds1d = self.ds1d.chunk({"dim_0": 50}).to_dataframe()
|
@@ -75,7 +85,7 @@ def time_agg_small_num_groups(self, method, ndim):
|
75 | 85 | @parameterized(["method", "ndim"], [("sum", "mean"), (1, 2)])
|
76 | 86 | def time_agg_large_num_groups(self, method, ndim):
|
77 | 87 | ds = getattr(self, f"ds{ndim}d")
|
78 |
| - getattr(ds.resample(time="24H"), method)() |
| 88 | + getattr(ds.resample(time="48H"), method)() |
79 | 89 |
|
80 | 90 |
|
81 | 91 | class ResampleDask(Resample):
|
|
0 commit comments