repair the issue where pickle are being read before they are written

This commit is contained in:
Thomas S Hatch 2011-03-16 22:41:11 -06:00
parent 7b60f6f30e
commit 47d33eb940

View file

@ -120,7 +120,11 @@ class LocalClient(object):
retp = os.path.join(jid_dir, fn_, 'return.p')
if not os.path.isfile(retp):
continue
ret[fn_] = pickle.load(open(retp, 'r'))
while not ret.has_key[fn_]:
try:
ret[fn_] = pickle.load(open(retp, 'r'))
except:
pass
if ret and start == 999999999999:
start = int(time.time())
if len(ret) >= len(minions):