add a chunksize attribute with numpy fake dask

LSSTDESC · Nov 1, 2024 · ca3505e · ca3505e
1 parent b4c095a
commit ca3505e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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,