diff options
| -rw-r--r-- | lib/presque/RestQueueBatchHandler.pm | 2 |
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 { |