()
| 5351 | |
| 5352 | |
| 5353 | def test_from_xarray_string_conversion(): |
| 5354 | xr = pytest.importorskip("xarray") |
| 5355 | |
| 5356 | x = np.random.randn(10) |
| 5357 | y = np.arange(10, dtype="uint8") |
| 5358 | t = list("abcdefghij") |
| 5359 | ds = xr.Dataset( |
| 5360 | {"a": ("t", da.from_array(x, chunks=4)), "b": ("t", y), "t": ("t", t)} |
| 5361 | ) |
| 5362 | expected_pd = pd.DataFrame({"a": x, "b": y}, index=pd.Index(t, name="t")) |
| 5363 | expected = dd.from_pandas(expected_pd, chunksize=4) |
| 5364 | actual = ds.to_dask_dataframe(set_index=True) |
| 5365 | assert isinstance(actual, dd.DataFrame) |
| 5366 | pd.testing.assert_frame_equal(actual.compute(), expected.compute()) |
| 5367 | |
| 5368 | |
| 5369 | def test_dataframe_into_delayed(): |
nothing calls this directly
no test coverage detected