commit 168f6094c4c9ff753995aac1c2213cd8d8c9a7f3
author koder aka kdanilov <kdanilov@mirantis.com> Sun Apr 19 02:33:38 2015 +0300
committer koder aka kdanilov <kdanilov@mirantis.com> Sun Apr 19 02:33:38 2015 +0300
tree e34e5e9168f7da7e3e6ee7c49cd9c992ade70bf4
parent cff7b2e130ab1e18422b80a723b4804de6783528

fixing, improve sersors installation code

wally/sensors/main.py

diff --git a/wally/sensors/main.py b/wally/sensors/main.py
index 3753e7c..e86bbed 100644
--- a/wally/sensors/main.py
+++ b/wally/sensors/main.py
@@ -51,6 +51,11 @@
     prev = {}
 
     while True:
+        try:
+            source_id = str(required_sensors.pop('source_id'))
+        except KeyError:
+            source_id = None
+
         gtime, data = get_values(required_sensors.items())
         curr = {'time': SensorInfo(gtime, True)}
         for name, val in data.items():
@@ -60,6 +65,10 @@
                 prev[name] = val.value
             else:
                 curr[name] = SensorInfo(val.value, False)
+
+        if source_id is not None:
+            curr['source_id'] = source_id
+
         sender.send(curr)
         time.sleep(opts.timeout)