projects
/
skytools.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
82bc079
)
pgq.BatchWalker: relaxed __len__(), ignore out-of-order calls
author
Marko Kreen
<markokr@gmail.com>
Wed, 24 Nov 2010 20:18:22 +0000
(22:18 +0200)
committer
Marko Kreen
<markokr@gmail.com>
Wed, 24 Nov 2010 20:18:22 +0000
(22:18 +0200)
python/pgq/consumer.py
patch
|
blob
|
blame
|
history
diff --git
a/python/pgq/consumer.py
b/python/pgq/consumer.py
index 20b83fe6922cba6f3bd3ee24666b193ff6c00a23..23eaa4f9331f354f1abd8f6e4c6de9e23ac18c4f 100644
(file)
--- a/
python/pgq/consumer.py
+++ b/
python/pgq/consumer.py
@@
-81,9
+81,6
@@
class _BatchWalker(object):
self.fetch_status = 2
def __len__(self):
- if self.fetch_status != 2:
- return -1
- #raise Exception("BatchWalker: len() for incomplete result. (%d)" % self.fetch_status)
return self.length
def tag_event_done(self, event):