From 4e615e60d706196163ed31dd90ad80ac9483b818 Mon Sep 17 00:00:00 2001 From: fjetter Date: Fri, 8 Sep 2023 15:55:20 +0200 Subject: [PATCH] remove finalize_compute from persist --- distributed/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/distributed/client.py b/distributed/client.py index 0b4214f2304..1e7b96b2aa5 100644 --- a/distributed/client.py +++ b/distributed/client.py @@ -3595,7 +3595,7 @@ def persist( result = [] for collection in collections: graph = ( - collection.finalize_compute().__dask_graph__() + collection.__dask_graph__() # Currently optimize should be called on client side to # fix dask keys .optimize()