From 5ef58cac0743bc49814b22900954d02744e2784a Mon Sep 17 00:00:00 2001 From: "Mads R. B. Kristensen" Date: Tue, 31 Mar 2020 06:58:31 -0700 Subject: [PATCH 1/2] order(): added hack to priorities "shuffle-split" --- dask/order.py | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/dask/order.py b/dask/order.py index 3aeb43412da..e6d51ae5891 100644 --- a/dask/order.py +++ b/dask/order.py @@ -507,6 +507,15 @@ 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(): + if len(k) > 0 and "split" in k[0]: + shuffle_split_keys.append(k) + + for k in shuffle_split_keys: + result[k] = 0 + return result From c8eff5f969cda3b4b07efec74bbdc59c25d688d3 Mon Sep 17 00:00:00 2001 From: "Mads R. B. Kristensen" Date: Tue, 22 Jun 2021 10:33:21 +0200 Subject: [PATCH 2/2] tmp --- dask/order.py | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/dask/order.py b/dask/order.py index e6d51ae5891..2726202c76a 100644 --- a/dask/order.py +++ b/dask/order.py @@ -507,14 +507,16 @@ 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(): - if len(k) > 0 and "split" in k[0]: - shuffle_split_keys.append(k) - - for k in shuffle_split_keys: - result[k] = 0 + # # 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