diff --git a/txpipe/utils/debuggable_dask.py b/txpipe/utils/debuggable_dask.py index b6dad209..015d3220 100644 --- a/txpipe/utils/debuggable_dask.py +++ b/txpipe/utils/debuggable_dask.py @@ -2,7 +2,9 @@ import os def from_array(arr, block_size): - return np.array(arr) + arr = np.array(arr) + arr.chunksize = 1 + return arr def compute(anything): return anything,