()
| 5384 | |
| 5385 | |
| 5386 | def test_array_to_df_conversion(): |
| 5387 | def foo(arr): |
| 5388 | return pd.DataFrame(arr) |
| 5389 | |
| 5390 | arr = da.random.random((100, 10), chunks=(10, 10)) |
| 5391 | result = arr.map_blocks(foo, meta=pd.DataFrame(np.random.random((1, 10)))) |
| 5392 | expected = pd.DataFrame(arr.compute()) |
| 5393 | assert_eq(result, expected, check_index=False) |
| 5394 | |
| 5395 | |
| 5396 | @pytest.mark.parametrize("npartitions", [1, 5]) |
nothing calls this directly
no test coverage detected