diff options
Diffstat (limited to 'lib/presque/worker/Role/Job.pm')
| -rw-r--r-- | lib/presque/worker/Role/Job.pm | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/presque/worker/Role/Job.pm b/lib/presque/worker/Role/Job.pm index 6ce317c..3681580 100644 --- a/lib/presque/worker/Role/Job.pm +++ b/lib/presque/worker/Role/Job.pm @@ -9,7 +9,12 @@ sub _job_failure { push @{$job->{fail}}, $err; my $retries = ($job->{retries_left} || $self->job_retries) - 1; $job->{retries_left} = $retries; - $self->rest_retry_job($job) if $retries > 0; + try { + $self->retry_job(queue_name => '', $job) if $retries > 0; + } + catch { + # XXX + }; $self->fail($job, $_) if $self->_has_fail_method; } |