about summary refs log tree commit diff
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-07-05 09:35:14 +0200
committerfranck cuny <franck@lumberjaph.net>2010-07-05 09:35:14 +0200
commitf16232838824a4aaae9528e88b65bdab29d24d0e (patch)
tree1fe381015af68f51dc25096596fca72428aef2d4
parentrefactor tests (diff)
parentfixed too strict inequality test in BatchHandler to send the correct (diff)
downloadpresque-f16232838824a4aaae9528e88b65bdab29d24d0e.tar.gz
Merge branch 'master' of http://github.com/ngrunwald/presque
* 'master' of http://github.com/ngrunwald/presque:
  fixed too strict inequality test in BatchHandler to send the correct number of jobs
-rw-r--r--lib/presque/RestQueueBatchHandler.pm2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm
index ef37045..48029a2 100644
--- a/lib/presque/RestQueueBatchHandler.pm
+++ b/lib/presque/RestQueueBatchHandler.pm
@@ -64,7 +64,7 @@ sub _get_jobs_from_queue {
                         my $job = shift;
                         push @$keys, $value;
                         push @$jobs, $job;
-                        if (++$pos >= ($batch_size - 1)) {
+                        if (++$pos > ($batch_size - 1)) {
                             $self->_finish_get($queue_name, $jobs, $keys);
                         }
                         else {