From 348525e03690ad28a8df4853445cdd088499a7de Mon Sep 17 00:00:00 2001 From: Steven Robertson Date: Fri, 13 Jan 2012 20:57:15 -0500 Subject: [PATCH] Fix retry --- worker.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/worker.py b/worker.py index 9279613..607e13e 100644 --- a/worker.py +++ b/worker.py @@ -179,8 +179,11 @@ def run_jobs(r, rev, jobs): waiting.remove(sidx) if sidx in retry: retry.remove(sidx) - pending.pop(sidx) - if retry and retry[0] < sidx: + if sidx in pending: + pending.pop(sidx) + else: + print 'Got two responses for %d' % sidx + if retry and retry[0] < sidx - 2 * QUEUE_LENGTH: # TODO: better exception raise ValueError("Double retry!") expired, waiting[:] = partition(lambda w: w < sidx - QUEUE_LENGTH,