From 785500b6ff1244e22f08051b391e425262c1ac51 Mon Sep 17 00:00:00 2001 From: Krishan Bhasin <8904718+KrishanBhasin@users.noreply.github.com> Date: Mon, 12 Oct 2020 18:28:40 +0000 Subject: [PATCH] Set Zict buffer target to maxsize when `memory_target_fraction` is False (#4156) --- distributed/worker.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/distributed/worker.py b/distributed/worker.py index 16a70db966..96cdf9e87e 100644 --- a/distributed/worker.py +++ b/distributed/worker.py @@ -557,7 +557,10 @@ def __init__( deserialize_bytes, File(path), ) - target = int(float(self.memory_limit) * self.memory_target_fraction) + target = ( + int(float(self.memory_limit) * self.memory_target_fraction) + or sys.maxsize + ) self.data = Buffer({}, storage, target, weight) self.data.memory = self.data.fast self.data.disk = self.data.slow