Log job termination. Avoid logging pending jobs.

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