summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSteve Kemp <steve@steve.org.uk>2012-11-13 14:27:05 +0000
committerSteve Kemp <steve@steve.org.uk>2012-11-13 14:27:05 +0000
commitd87a26c96e51a28416f5a6af1b0999c5fda5fe5e (patch)
treed1e6c69da2d9e494aec92b1e7940570d9596ffba
parent101c173611accfb2cbc5bab5774fc1915c19335b (diff)
Log job termination. Avoid logging pending jobs.
-rwxr-xr-xworker/worker9
1 files changed, 2 insertions, 7 deletions
diff --git a/worker/worker b/worker/worker
index 6fb7027..739f582 100755
--- a/worker/worker
+++ b/worker/worker
@@ -191,13 +191,7 @@ class Custodian
begin
job = @queue.reserve()
- #
- # Get the count of pending jobs
- #
- stats = @queue.stats()
- pend = stats['current-jobs-ready'] || 0
-
- log_message( "Job aquired. Job ID : #{job.id} pending jobs:#{pend}" )
+ log_message( "Job aquired - Job ID : #{job.id}" )
#
@@ -296,6 +290,7 @@ class Custodian
# we should remove it to avoid picking it up again, or we handled
# it successfully so it should be removed.
#
+ log_message( "Job ID : #{job.id} - Removed" )
job.delete if ( job )
end
end