diff options
| -rwxr-xr-x | worker/worker | 9 |
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 |