From 5b2042053577cc6381c40c4fb5d5264e79a0312d Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Wed, 9 Jun 2010 18:19:38 +0200
Subject: add logger; move some code for work and job in roles;

---
 lib/presque/worker/Role/Job.pm | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100644 lib/presque/worker/Role/Job.pm

(limited to 'lib/presque/worker/Role/Job.pm')

diff --git a/lib/presque/worker/Role/Job.pm b/lib/presque/worker/Role/Job.pm
new file mode 100644
index 0000000..6ce317c
--- /dev/null
+++ b/lib/presque/worker/Role/Job.pm
@@ -0,0 +1,16 @@
+package presque::worker::Role::Job;
+
+use Moose::Role;
+has job_retries    => (is => 'rw', isa => 'Int', default  => 5);
+
+sub _job_failure {
+    my ($self, $job, $err) = @_;
+
+    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;
+    $self->fail($job, $_) if $self->_has_fail_method;
+}
+
+1;
-- 
cgit v1.2.3