summaryrefslogtreecommitdiff
path: root/worker
diff options
context:
space:
mode:
Diffstat (limited to 'worker')
-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