diff options
Diffstat (limited to 'lib/presque/RestQueueBatchHandler.pm')
| -rw-r--r-- | lib/presque/RestQueueBatchHandler.pm | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm index abdbe5e..311f223 100644 --- a/lib/presque/RestQueueBatchHandler.pm +++ b/lib/presque/RestQueueBatchHandler.pm @@ -62,6 +62,7 @@ sub _get_jobs_from_queue { $value, sub { my $job = shift; + $self->application->redis->del($value); push @$keys, $value; push @$jobs, $job; if (++$pos > ($batch_size - 1)) { |