vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Fix the allocator to use id ranges instead of limits

Browse source
This commit is contained in:
Jake Moshenko 2016-01-12 15:21:13 -05:00
parent 3c32c3319c
commit aaf462682f
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
util/migrate/allocator.py
View file

@ -133,8 +133,8 @@ def yield_random_entries(batch_query, primary_key_field, batch_size, max_id):
while True:
start_index = allocator.get_block_start_index(batch_size)
all_candidates = list(batch_query()
.limit(batch_size)
.where(primary_key_field >= start_index))
.where(primary_key_field >= start_index,
primary_key_field <= start_index + batch_size))
if len(all_candidates) == 0:
logger.info('No candidates, new highest id: %s', start_index)