()
| 794 | |
| 795 | |
| 796 | def test_bag_array_conversion(): |
| 797 | import dask.bag as db |
| 798 | |
| 799 | b = db.range(10, npartitions=1) |
| 800 | (x,) = b.map_partitions(np.asarray).to_delayed() |
| 801 | (x,) = (da.from_delayed(a, shape=(10,), dtype=int) for a in [x]) |
| 802 | z = da.concatenate([x]) |
| 803 | assert_eq(z, np.arange(10), check_graph=False) |
| 804 | |
| 805 | |
| 806 | def test_svd(): |
nothing calls this directly
no test coverage detected