|
20 | 20 | from flox.xrutils import isnull, notnull
|
21 | 21 |
|
22 | 22 | from . import assert_equal
|
23 |
| -from .strategies import array_dtypes, by_arrays, chunked_arrays, func_st, numeric_arrays |
| 23 | +from .strategies import by_arrays, chunked_arrays, func_st, numeric_dtypes, numeric_like_arrays |
24 | 24 | from .strategies import chunks as chunks_strategy
|
25 | 25 |
|
26 | 26 | dask.config.set(scheduler="sync")
|
@@ -66,7 +66,7 @@ def not_overflowing_array(array: np.ndarray[Any, Any]) -> bool:
|
66 | 66 |
|
67 | 67 | @given(
|
68 | 68 | data=st.data(),
|
69 |
| - array=st.one_of(numeric_arrays, chunked_arrays(arrays=numeric_arrays)), |
| 69 | + array=st.one_of(numeric_like_arrays, chunked_arrays(arrays=numeric_like_arrays)), |
70 | 70 | func=func_st,
|
71 | 71 | )
|
72 | 72 | def test_groupby_reduce(data, array, func: str) -> None:
|
@@ -136,7 +136,7 @@ def test_groupby_reduce(data, array, func: str) -> None:
|
136 | 136 |
|
137 | 137 | @given(
|
138 | 138 | data=st.data(),
|
139 |
| - array=chunked_arrays(arrays=numeric_arrays), |
| 139 | + array=chunked_arrays(arrays=numeric_like_arrays), |
140 | 140 | func=func_st,
|
141 | 141 | )
|
142 | 142 | def test_groupby_reduce_numpy_vs_dask(data, array, func: str) -> None:
|
@@ -170,7 +170,7 @@ def test_groupby_reduce_numpy_vs_dask(data, array, func: str) -> None:
|
170 | 170 | @settings(report_multiple_bugs=False)
|
171 | 171 | @given(
|
172 | 172 | data=st.data(),
|
173 |
| - array=chunked_arrays(arrays=numeric_arrays), |
| 173 | + array=chunked_arrays(arrays=numeric_like_arrays), |
174 | 174 | func=st.sampled_from(tuple(NUMPY_SCAN_FUNCS)),
|
175 | 175 | )
|
176 | 176 | def test_scans(data, array: dask.array.Array, func: str) -> None:
|
@@ -297,8 +297,8 @@ def test_first_last_useless(data, func):
|
297 | 297 | @given(
|
298 | 298 | func=st.sampled_from(["sum", "prod", "nansum", "nanprod"]),
|
299 | 299 | engine=st.sampled_from(["numpy", "flox"]),
|
300 |
| - array_dtype=st.none() | array_dtypes, |
301 |
| - dtype=st.none() | array_dtypes, |
| 300 | + array_dtype=st.none() | numeric_dtypes, |
| 301 | + dtype=st.none() | numeric_dtypes, |
302 | 302 | )
|
303 | 303 | def test_agg_dtype_specified(func, array_dtype, dtype, engine):
|
304 | 304 | # regression test for GH388
|
|
0 commit comments