diff --git a/dask_expr/_shuffle.py b/dask_expr/_shuffle.py index 925142266..cc3b8c0d0 100644 --- a/dask_expr/_shuffle.py +++ b/dask_expr/_shuffle.py @@ -423,7 +423,7 @@ def _layer(self): _filter = None shuffle_group_name = "group-" + name - split_name = "split-" + name + split_name = "split-" + name_input for global_part, part in enumerate(parts_out): out = inputs[part]