diff options
author | franck cuny <franck@lumberjaph.net> | 2010-05-15 11:20:28 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-05-15 11:20:28 +0200 |
commit | 02df58bb3804ff3ebafabb35bbf8a9cc63224cae (patch) | |
tree | de42c2ca384b7a115c057f23d5e88bff7d7eae26 /lib | |
parent | return some stats about workers (diff) | |
download | presque-02df58bb3804ff3ebafabb35bbf8a9cc63224cae.tar.gz |
stats about processed and failed jobs
Diffstat (limited to '')
-rw-r--r-- | lib/presque/RestQueueHandler.pm | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/presque/RestQueueHandler.pm b/lib/presque/RestQueueHandler.pm index 6378726..d1db977 100644 --- a/lib/presque/RestQueueHandler.pm +++ b/lib/presque/RestQueueHandler.pm @@ -107,6 +107,7 @@ sub put { my $worker_id = $input->{worker_id} if $input && $input->{worker_id}; $self->application->redis->incr('failed'); + $self->application->redis->incr($self->_queue_failed($queue_name)); if ($worker_id) { $self->application->redis->incr('failed:' . $worker_id); } @@ -117,7 +118,7 @@ sub put { sub delete { my ($self, $queue_name) = @_; - # delete delayed queue + # XXX delete failed && processed my $lkey = $self->_queue($queue_name); my $dkey = $self->_queue_delayed($queue_name); @@ -130,7 +131,8 @@ sub delete { sub _finish_get { my ($self, $job, $queue_name, $worker_id) = @_; - $self->application->redis->incr('processed'); + $self->application->redis->incr('processed'); + $self->application->redis->incr($self->_queue_processed($queue_name)); if ($worker_id) { $self->application->redis->set( $self->_queue_worker($worker_id), @@ -140,7 +142,7 @@ sub _finish_get { } ) ); - $self->application->redis->incr('processed:' . $worker_id); + $self->application->redis->incr('processed:' . $worker_id); } $self->finish($job); } |