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