Remove weakref finalizer for Offload Executor (dask#7644)

ypogorelova · Mar 16, 2023 · cca25f7 · cca25f7
1 parent 9151b38
commit cca25f7
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/distributed/utils.py b/distributed/utils.py
@@ -1397,7 +1397,6 @@ def is_valid_xml(text):
 
 
 _offload_executor = ThreadPoolExecutor(max_workers=1, thread_name_prefix="Dask-Offload")
-weakref.finalize(_offload_executor, _offload_executor.shutdown)
 
 
 def import_term(name: str) -> AnyType: