From 23603127362e6f4a7606325501a3ce26ef8317a1 Mon Sep 17 00:00:00 2001
From: msil <michael.silas@sohonet.com>
Date: Tue, 26 Jun 2018 14:09:20 +0100
Subject: adding node group to worker logs

pr #1420
---
 lib/oxidized/worker.rb | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/lib/oxidized/worker.rb b/lib/oxidized/worker.rb
index 4b9614b..3fc1cee 100644
--- a/lib/oxidized/worker.rb
+++ b/lib/oxidized/worker.rb
@@ -29,7 +29,7 @@ module Oxidized
         node = @nodes.get
         node.running? ? next : node.running = true
         @jobs.push Job.new node
-        Oxidized.logger.debug "lib/oxidized/worker.rb: Added #{node.name} to the job queue"
+        Oxidized.logger.debug "lib/oxidized/worker.rb: Added #{node.group}/#{node.name} to the job queue"
       end
 
       run_done_hook if is_cycle_finished?
@@ -48,7 +48,7 @@ module Oxidized
         process_failure node, job
       end
     rescue NodeNotFound
-      Oxidized.logger.warn "#{node.name} not found, removed while collecting?"
+      Oxidized.logger.warn "#{node.group}/#{node.name} not found, removed while collecting?"
     end
 
     private
@@ -57,7 +57,7 @@ module Oxidized
       @jobs_done += 1 # needed for :nodes_done hook
       Oxidized.Hooks.handle :node_success, node: node,
                                            job: job
-      msg = "update #{node.name}"
+      msg = "update #{node.group}/#{node.name}"
       msg += " from #{node.from}" if node.from
       msg += " with message '#{node.msg}'" if node.msg
       output = node.output.new
@@ -73,7 +73,7 @@ module Oxidized
     end
 
     def process_failure node, job
-      msg = "#{node.name} status #{job.status}"
+      msg = "#{node.group}/#{node.name} status #{job.status}"
       if node.retry < Oxidized.config.retries
         node.retry += 1
         msg += ", retry attempt #{node.retry}"
-- 
cgit v1.2.1