diff --git a/wally/sensors_utils.py b/wally/sensors_utils.py
index 3cd6bc8..18e8d3e 100644
--- a/wally/sensors_utils.py
+++ b/wally/sensors_utils.py
@@ -14,7 +14,7 @@
 logger = logging.getLogger("wally")
 
 
-def save_sensors_data(data_q, mon_q, fd):
+def save_sensors_data(data_q, mon_q, fd, sensors_configs):
     fd.write("\n")
 
     observed_nodes = set()
@@ -26,11 +26,13 @@
                 break
 
             addr, data = val
+
             if addr not in observed_nodes:
                 mon_q.put(addr + (data['source_id'],))
                 observed_nodes.add(addr)
 
-            fd.write("{0!s} : {1!r}\n".format(time.time(), repr(val)))
+            fd.write("{0!s} : {1!r}\n".format(time.time(),
+                     repr((addr, data))))
     except Exception:
         logger.exception("Error in sensors thread")
     logger.info("Sensors thread exits")
@@ -76,7 +78,8 @@
     mon_q = Queue.Queue()
     fd = open(cfg_dict['sensor_storage'], "w")
     sensor_listen_th = threading.Thread(None, save_sensors_data, None,
-                                        (sensors_data_q, mon_q, fd))
+                                        (sensors_data_q, mon_q, fd,
+                                         sensors_configs))
     sensor_listen_th.daemon = True
     sensor_listen_th.start()