Skip to content

Commit 245d700

Browse files
committed
fix: skip caught StopIteration *instances*
1 parent bcb63cf commit 245d700

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

taskqueue/taskqueue.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -574,7 +574,8 @@ def capturing_soloprocess_upload(*args, **kwargs):
574574
with pathos.pools.ProcessPool(parallel, context=spawn_ctx) as pool:
575575
for num_inserted, err in pool.imap(uploadfn, sip(tasks, block_size)):
576576
if err is not None:
577-
errors.append(err)
577+
if not isinstance(err, StopIteration):
578+
errors.append(err)
578579
continue
579580
pbar.update(num_inserted)
580581
ct += num_inserted

0 commit comments

Comments
 (0)