diff --git a/src/dask_awkward/lib/io/io.py b/src/dask_awkward/lib/io/io.py index db35791b..b082cce3 100644 --- a/src/dask_awkward/lib/io/io.py +++ b/src/dask_awkward/lib/io/io.py @@ -721,7 +721,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