diff --git a/dask/order.py b/dask/order.py index 3aeb43412da..2726202c76a 100644 --- a/dask/order.py +++ b/dask/order.py @@ -507,6 +507,17 @@ def finish_now_key(x): item = init_stack_pop() inner_stacks_append([item]) + # # TODO: Hack to priorities "shuffle-split" + # shuffle_split_keys = [] + # for k in result.keys(): + # print("k: ", repr(k)) + # if "split" in k: + # shuffle_split_keys.append(k) + + # print("shuffle_split_keys: ", shuffle_split_keys) + # for k in shuffle_split_keys: + # result[k] = 0 + return result