pgq.BatchWalker: relaxed __len__(), ignore out-of-order calls
authorMarko Kreen <markokr@gmail.com>
Wed, 24 Nov 2010 20:18:22 +0000 (22:18 +0200)
committerMarko Kreen <markokr@gmail.com>
Wed, 24 Nov 2010 20:18:22 +0000 (22:18 +0200)
python/pgq/consumer.py

index 20b83fe6922cba6f3bd3ee24666b193ff6c00a23..23eaa4f9331f354f1abd8f6e4c6de9e23ac18c4f 100644 (file)
@@ -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):