From f7035fc527be5137baba3ce2f8d1702d1fe4a652 Mon Sep 17 00:00:00 2001 From: Andreas Lemke Date: Sun, 24 May 2026 13:01:53 +0200 Subject: [PATCH 1/2] Add retries for Venus C modbus communication --- packages/modules/devices/marstek/venus_c_e/device.py | 3 ++- requirements.txt | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/packages/modules/devices/marstek/venus_c_e/device.py b/packages/modules/devices/marstek/venus_c_e/device.py index 6b402bad0e..149579ae71 100644 --- a/packages/modules/devices/marstek/venus_c_e/device.py +++ b/packages/modules/devices/marstek/venus_c_e/device.py @@ -27,7 +27,8 @@ def update_components(components: Iterable[VenusCEBat]): def initializer(): nonlocal client - client = ModbusTcpClient_(device_config.configuration.ip_address, device_config.configuration.port) + client = ModbusTcpClient_(device_config.configuration.ip_address, device_config.configuration.port, + retry_on_empty=True, retry_on_invalid=True, retries=2, timeout=2) return ConfigurableDevice( device_config=device_config, diff --git a/requirements.txt b/requirements.txt index d3f1163050..4f2e33f044 100644 --- a/requirements.txt +++ b/requirements.txt @@ -2,7 +2,7 @@ typing-extensions==4.13.2 jq==1.1.3 paho_mqtt==1.6.1 -pymodbus==2.5.2 +pymodbus==2.5.3 pytest==6.2.5 requests_mock==1.9.3 lxml==4.9.1 From 9a9a755bf93c169f91fce80180eba6a2569ffa03 Mon Sep 17 00:00:00 2001 From: Andreas Lemke Date: Sun, 24 May 2026 13:13:23 +0200 Subject: [PATCH 2/2] Remove trailing whitespace --- packages/modules/devices/marstek/venus_c_e/device.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/modules/devices/marstek/venus_c_e/device.py b/packages/modules/devices/marstek/venus_c_e/device.py index 149579ae71..dd431ddf6d 100644 --- a/packages/modules/devices/marstek/venus_c_e/device.py +++ b/packages/modules/devices/marstek/venus_c_e/device.py @@ -27,7 +27,7 @@ def update_components(components: Iterable[VenusCEBat]): def initializer(): nonlocal client - client = ModbusTcpClient_(device_config.configuration.ip_address, device_config.configuration.port, + client = ModbusTcpClient_(device_config.configuration.ip_address, device_config.configuration.port, retry_on_empty=True, retry_on_invalid=True, retries=2, timeout=2) return ConfigurableDevice(