diff options
| author | Nils Grunwald <nils.grunwald@gmail.com> | 2010-07-04 18:28:04 +0200 |
|---|---|---|
| committer | Nils Grunwald <nils.grunwald@gmail.com> | 2010-07-04 18:28:04 +0200 |
| commit | dd95a41941c6367aa1392afd29d7d5969f092898 (patch) | |
| tree | be07e71722eee65d858c55bd55bb9a6c68bc7675 /lib/presque/RestQueueBatchHandler.pm | |
| parent | update README (diff) | |
| download | presque-dd95a41941c6367aa1392afd29d7d5969f092898.tar.gz | |
fixed too strict inequality test in BatchHandler to send the correct
number of jobs
Diffstat (limited to '')
| -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 { |