MCPcopy
hub / github.com/dask/dask / test_from_xarray

Function test_from_xarray

dask/dataframe/tests/test_dataframe.py:5292–5307  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

5290
5291
5292def test_from_xarray():
5293 xr = pytest.importorskip("xarray")
5294
5295 a = da.zeros(shape=(6000, 45000), chunks=(30, 6000))
5296 a = xr.DataArray(
5297 a, coords={"c1": list(range(6000)), "c2": list(range(45000))}, dims=["c1", "c2"]
5298 )
5299 sel_coords = {
5300 "c1": pd.date_range("2024-11-01", "2024-11-10").to_numpy(),
5301 "c2": [29094],
5302 }
5303
5304 result = a.reindex(**sel_coords).to_dask_dataframe()
5305 assert (
5306 len(collections_to_expr([result]).optimize().__dask_graph__()) < 30
5307 ) # previously 3000
5308
5309
5310def test_from_xarray_string_conversion():

Callers

nothing calls this directly

Calls 5

collections_to_exprFunction · 0.90
to_dask_dataframeMethod · 0.80
zerosMethod · 0.45
__dask_graph__Method · 0.45
optimizeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…