Pull data outside of while loop in gather
See
@@ -1391,6 +1391,7 @@ class Client(Node):
futures2, keys = unpack_remotedata(futures, byte_keys=True)
keys = [tokey(key) for key in keys]
bad_data = dict()
+ data = {}
if direct is None:
try:
@@ -1445,8 +1446,6 @@ class Client(Node):
keys = [k for k in keys if k not in bad_keys]
- data = {}
-
if local_worker: # look inside local worker
data.update({k: local_worker.data[k]
for k in keys
