component-wise error handling

Author: LKuemmel

docs/samples/sample_modbus/sample_modbus/device.py

@@ -3,6 +3,7 @@
 from typing import Iterable,  Union
 
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ConfigurableDevice, ComponentFactoryByType, MultiComponentUpdater
 from modules.common.modbus import ModbusTcpClient_
 from modules.devices.sample_modbus.sample_modbus.bat import SampleBat
@@ -31,7 +32,8 @@ def create_inverter_component(component_config: SampleInverterSetup):
     def update_components(components: Iterable[Union[SampleBat, SampleCounter, SampleInverter]]):
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client

docs/samples/sample_request_by_device/sample_request_by_device/device.py

@@ -4,6 +4,7 @@
 
 from modules.common import req
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ConfigurableDevice, ComponentFactoryByType, MultiComponentUpdater
 from modules.devices.sample_request_by_device.sample_request_by_device.bat import SampleBat
 from modules.devices.sample_request_by_device.sample_request_by_device.config import Sample, SampleBatSetup, SampleCounterSetup, SampleInverterSetup
@@ -26,7 +27,8 @@ def create_inverter_component(component_config: SampleInverterSetup):
     def update_components(components: Iterable[Union[SampleBat, SampleCounter, SampleInverter]]):
         response = req.get_http_session().get(device_config.configuration.ip_address, timeout=5).json()
         for component in components:
-            component.update(response)
+            with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                component.update(response)
 
     return ConfigurableDevice(
         device_config=device_config,

packages/modules/devices/algodue/algodue/device.py

@@ -23,7 +23,7 @@ def create_counter_component(component_config: AlgodueCounterSetup):
     def update_components(components: Iterable[counter.AlgodueCounter]):
         with client:
             for component in components:
-                with SingleComponentUpdateContext(component.fault_state):
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
                     component.update()
 
     def initializer():

packages/modules/devices/alpha_ess/alpha_ess/device.py

@@ -4,6 +4,7 @@
 from typing import Iterable, Union
 
 from helpermodules.utils.run_command import run_command
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ComponentFactoryByType, ConfigurableDevice, MultiComponentUpdater
 from modules.devices.alpha_ess.alpha_ess.config import (
     AlphaEss, AlphaEssBatSetup, AlphaEssCounterSetup, AlphaEssInverterSetup)
@@ -48,7 +49,8 @@ def update_components(components: Iterable[Union[alpha_ess_component_classes]]):
         nonlocal client
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client

packages/modules/devices/ampere/ampere/device.py

@@ -3,6 +3,7 @@
 from typing import Iterable, Union
 
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ComponentFactoryByType, ConfigurableDevice, MultiComponentUpdater
 from modules.common.modbus import ModbusTcpClient_
 from modules.devices.ampere.ampere.bat import AmpereBat
@@ -40,7 +41,8 @@ def create_inverter_component(component_config: AmpereInverterSetup):
     def update_components(components: Iterable[Union[AmpereBat, AmpereCounter, AmpereInverter]]):
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client

packages/modules/devices/avm/avm/device.py

@@ -9,6 +9,7 @@
 from helpermodules.pub import Pub
 from modules.common import req
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ConfigurableDevice, ComponentFactoryByType, MultiComponentUpdater
 from modules.devices.avm.avm.config import Avm, AvmCounterSetup
 from modules.devices.avm.avm.counter import AvmCounter
@@ -36,7 +37,8 @@ def update_components(components: Iterable[AvmCounter]):
         deviceListElementTree = ET.fromstring(response.text.strip())
 
         for component in components:
-            component.update(deviceListElementTree)
+            with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                component.update(deviceListElementTree)
 
     def get_session_id():
         # checking existing sessionID

packages/modules/devices/azzurro_zcs/azzurro_zcs/device.py

@@ -3,6 +3,7 @@
 from typing import Iterable, Union
 
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ConfigurableDevice, ComponentFactoryByType, MultiComponentUpdater
 from modules.common.modbus import ModbusTcpClient_
 from modules.devices.azzurro_zcs.azzurro_zcs.bat import ZCSBat
@@ -36,7 +37,8 @@ def update_components(components: Iterable[Union[ZCSBat, ZCSCounter, ZCSInverter
         nonlocal client
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client

packages/modules/devices/batterx/batterx/device.py

@@ -4,7 +4,7 @@
 
 from helpermodules.cli import run_using_positional_cli_args
 from modules.common.abstract_device import DeviceDescriptor
-from modules.common.component_context import MultiComponentUpdateContext
+from modules.common.component_context import MultiComponentUpdateContext, SingleComponentUpdateContext
 from modules.common.configurable_device import ComponentFactoryByType, ConfigurableDevice, MultiComponentUpdater
 from modules.common.store import get_inverter_value_store
 from modules.devices.batterx.batterx import bat, external_inverter
@@ -39,7 +39,8 @@ def update_components(components: Iterable[batterx_component_classes]):
             'http://' + device_config.configuration.ip_address + '/api.php?get=currentstate',
             timeout=5).json()
         for component in components:
-            component.update(resp_json)
+            with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                component.update(resp_json)
 
     return ConfigurableDevice(
         device_config=device_config,

packages/modules/devices/carlo_gavazzi/carlo_gavazzi/device.py

@@ -2,6 +2,7 @@
 import logging
 from typing import Iterable
 
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ComponentFactoryByType, ConfigurableDevice, MultiComponentUpdater
 from modules.devices.carlo_gavazzi.carlo_gavazzi import counter
 from modules.devices.carlo_gavazzi.carlo_gavazzi.config import CarloGavazzi, CarloGavazziCounterSetup
@@ -23,7 +24,8 @@ def update_components(components: Iterable[counter.CarloGavazziCounter]):
         nonlocal client
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client

packages/modules/devices/deye/deye/device.py

@@ -4,6 +4,7 @@
 
 from helpermodules.cli import run_using_positional_cli_args
 from modules.common.abstract_device import DeviceDescriptor
+from modules.common.component_context import SingleComponentUpdateContext
 from modules.common.configurable_device import ConfigurableDevice, ComponentFactoryByType, MultiComponentUpdater
 from modules.common.modbus import ModbusTcpClient_
 from modules.devices.deye.deye.bat import DeyeBat
@@ -34,7 +35,8 @@ def update_components(components: Iterable[Union[DeyeBat, DeyeCounter, DeyeInver
         nonlocal client
         with client:
             for component in components:
-                component.update()
+                with SingleComponentUpdateContext(component.fault_state, update_always=False):
+                    component.update()
 
     def initializer():
         nonlocal client