Fix stacktrace in batch with dup minion ids

Resolves #32661
This commit is contained in:
Mike Place 2016-04-19 10:39:31 -06:00
parent 7307bcb88e
commit f704df90bc

View File

@ -165,7 +165,8 @@ class Batch(object):
else:
parts.update(part)
for id in part.keys():
minion_tracker[queue]['minions'].remove(id)
if id in minion_tracker[queue]['minions']:
minion_tracker[queue]['minions'].remove(id)
except StopIteration:
# if a iterator is done:
# - set it to inactive