diff --git a/src/dask_histogram/core.py b/src/dask_histogram/core.py index f46a0bd..4f3cec7 100644 --- a/src/dask_histogram/core.py +++ b/src/dask_histogram/core.py @@ -984,11 +984,12 @@ def _partitioned_histogram_multifill( name = f"hist-on-block-{tokenize(data, histref, weights, samples)}" from dask.base import unpack_collections - from dask_awkward.lib.core import partitionwise_layer as dak_pwl flattened_deps, repacker = unpack_collections(data, weights, samples, histref) if is_dask_awkward_like(flattened_deps[0]): + from dask_awkward.lib.core import partitionwise_layer as dak_pwl + unpacked_multifill = partial(_blocked_multi_dak, repacker) graph = dak_pwl(unpacked_multifill, name, *flattened_deps) elif is_dataframe_like(flattened_deps[0]):