Delay zwave updates for 100ms to group them.

homeassistant/components/zwave/__init__.py

@@ -12,6 +12,7 @@
 
 import voluptuous as vol
 
+from homeassistant.core import callback
 from homeassistant.loader import get_platform
 from homeassistant.helpers import discovery
 from homeassistant.const import (
@@ -769,6 +770,7 @@ def __init__(self, value, domain):
         self._wakeup_value_id = None
         self._battery_value_id = None
         self._power_value_id = None
+        self._scheduled_update = False
         self._update_attributes()
 
         dispatcher.connect(
@@ -793,8 +795,10 @@ def value_changed(self):
         self.update_properties()
         # If value changed after device was created but before setup_platform
         # was called - skip updating state.
-        if self.hass:
-            self.schedule_update_ha_state()
+        if self.hass and not self._scheduled_update:
+            self._schedule_update()
+        else:
+            _LOGGER.info('Skip update for %s. It is already scheduled', self.entity_id)
 
     def _update_ids(self):
         """Update value_ids from which to pull attributes."""
@@ -916,3 +920,15 @@ def refresh_from_network(self):
             return
         for value_id in dependent_ids + [self._value.value_id]:
             self._value.node.refresh_value(value_id)
+
+    def _schedule_update(self):
+        """Schedule delayed update."""
+        @callback
+        def do_update():
+            """Really update."""
+            self.hass.add_job(self.async_update_ha_state())
+            self._scheduled_update = False
+
+        self.hass.loop.call_soon_threadsafe(
+            self.hass.loop.call_later, 0.1, do_update)
+        self._scheduled_update = True