preserve divisions

dask-contrib · Nov 15, 2023 · 93bcf5a · 93bcf5a
1 parent e838cdf
commit 93bcf5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py
@@ -688,7 +688,7 @@ def from_map(
         result = new_array_object(hlg, name, meta=array_meta, npartitions=len(inputs))
 
     if empty_on_raise and empty_backend:
-        res = result.map_partitions(first, meta=array_meta)
+        res = result.map_partitions(first, meta=array_meta, output_divisions=1)
         rep = result.map_partitions(second, meta=empty_typetracer())
         return res, rep