From e78bf88d692661b65e9832f34d23cfc278c31458 Mon Sep 17 00:00:00 2001 From: Patrick Hoefler <61934744+phofl@users.noreply.github.com> Date: Fri, 8 Mar 2024 17:14:15 +0100 Subject: [PATCH] Change split names in task based shuffle --- dask_expr/_shuffle.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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]