Fix concurrency issue

Download_list sometimes failed with:
BrokenPipeError: [Errno 32] Broken pipe
master
J. Fernando Sánchez 5 years ago
parent fadeced761
commit 40a8b45231

@ -1 +1 @@
0.9.6
0.9.7

@ -595,7 +595,9 @@ def download_list(wq, lst, folder, update=False, retry_failed=False, ignore_fail
def gen():
while True:
r = down.get()
if not r:
if r is None:
down.close()
down.join_thread()
return
yield r
@ -622,6 +624,8 @@ def download_list(wq, lst, folder, update=False, retry_failed=False, ignore_fail
rec = done.get()
if rec is None:
done.close()
done.join_thread()
break
oid, obj = rec

Loading…
Cancel
Save