File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -136,6 +136,7 @@ async def poll(self) -> None:
136
136
137
137
await self .ensure_client ()
138
138
139
+ values_by_type_and_address : dict [str , dict [int , Any ]] = {}
139
140
for modbus_type , lengths_by_address in self ._lengths_by_type_and_address .items ():
140
141
for address , length in lengths_by_address .items ():
141
142
if modbus_type == constants .MODBUS_TYPE_COIL :
@@ -185,11 +186,12 @@ async def poll(self) -> None:
185
186
continue
186
187
187
188
if len (values ) < length :
188
- self .error ('unexpected number of values read: %s < %s' , len (values ), length )
189
- continue
189
+ raise Exception ('Unexpected number of values read: %s < %s' , len (values ), length )
190
190
191
191
for i in range (length ):
192
- self ._values_by_type_and_address .setdefault (modbus_type , {})[address + i ] = values [i ]
192
+ values_by_type_and_address .setdefault (modbus_type , {})[address + i ] = values [i ]
193
+
194
+ self ._values_by_type_and_address = values_by_type_and_address
193
195
194
196
def get_last_coil_value (self , address : int ) -> Optional [bool ]:
195
197
values_by_address = self ._values_by_type_and_address .get (constants .MODBUS_TYPE_COIL , {})
You can’t perform that action at this time.
0 commit comments