diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-28 08:21:45 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-28 08:21:45 +0200 |
| commit | f938839f3f914da5822576091bec3511f0e7ae8c (patch) | |
| tree | e00f008ef977d2146504f91bde0c3d9fb6a017b4 /lib/presque/worker/Role/Job.pm | |
| parent | use net::presque and add some delegation (diff) | |
| download | presque-worker-f938839f3f914da5822576091bec3511f0e7ae8c.tar.gz | |
logger read from context; more net::presque
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; } |