mirror-github-bspeice/cuburn
1
0
Fork 0
mirror of https://github.com/stevenrobertson/cuburn.git synced 2025-11-04 02:10:45 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Avoid spurious exceptions for now

Browse Source
This commit is contained in:
Steven Robertson
2012-02-14 10:31:24 -08:00
parent 55f7636fc0
commit d7ca907488
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
worker.py
View File

@ -207,8 +207,9 @@ def run_jobs(r, rev, jobs):
else: else:
print 'Got two responses for %d' % sidx print 'Got two responses for %d' % sidx
if retry and retry[0] < sidx - 2 * QUEUE_LENGTH: if retry and retry[0] < sidx - 2 * QUEUE_LENGTH:
# TODO: better exception # TODO: ensure that this doesn't happen accidentally; raise an
raise ValueError("Double retry!") # appropriate exception when it does
print "Double retry!"
expired, waiting[:] = partition(lambda w: w < sidx - QUEUE_LENGTH, expired, waiting[:] = partition(lambda w: w < sidx - QUEUE_LENGTH,
waiting) waiting)
for i in expired: for i in expired: