mirror-github-bspeice/cuburn
1
0
Fork 0
mirror of https://github.com/stevenrobertson/cuburn.git synced 2025-04-21 09:01:31 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix retry

Browse Source
This commit is contained in:
Steven Robertson 2012-01-13 20:57:15 -05:00
parent c9693b12ae
commit 348525e036
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
worker.py
View File

@ -179,8 +179,11 @@ def run_jobs(r, rev, jobs):
waiting.remove(sidx) waiting.remove(sidx)
if sidx in retry: if sidx in retry:
retry.remove(sidx) retry.remove(sidx)
if sidx in pending:
pending.pop(sidx) pending.pop(sidx)
if retry and retry[0] < sidx: else:
print 'Got two responses for %d' % sidx
if retry and retry[0] < sidx - 2 * QUEUE_LENGTH:
# TODO: better exception # TODO: better exception
raise ValueError("Double retry!") raise ValueError("Double retry!")
expired, waiting[:] = partition(lambda w: w < sidx - QUEUE_LENGTH, expired, waiting[:] = partition(lambda w: w < sidx - QUEUE_LENGTH,