fix code style

Browse Source
This commit is contained in:
Nigel Dokter 2023-01-01 20:55:58 +01:00
parent f851f48225
commit 0a259a3c9d
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
dsmr_parser/clients/serial_.py
View File

@ -95,15 +95,15 @@ class AsyncSerialReader(SerialReader):
) )
except ParseError as e: except ParseError as e:
logger.warning('Failed to parse telegram: %s', e) logger.warning('Failed to parse telegram: %s', e)
async def read_as_object(self, queue): async def read_as_object(self, queue):
""" """
Read complete DSMR telegram's from the serial interface Read complete DSMR telegram's from the serial interface
and return a Telegram object. and return a Telegram object.
Instead of being a generator, Telegram objects are pushed Instead of being a generator, Telegram objects are pushed
to provided queue for asynchronous processing. to provided queue for asynchronous processing.
:rtype: None :rtype: None
""" """
@ -119,12 +119,11 @@ class AsyncSerialReader(SerialReader):
self.telegram_buffer.append(data.decode('ascii')) self.telegram_buffer.append(data.decode('ascii'))
for telegram in self.telegram_buffer.get_all(): for telegram in self.telegram_buffer.get_all():
try:
try: queue.put_nowait(
queue.put_nowait( Telegram(telegram, self.telegram_parser, self.telegram_specification)
Telegram(telegram, self.telegram_parser, self.telegram_specification) )
) except InvalidChecksumError as e:
except InvalidChecksumError as e: logger.warning(str(e))
logger.warning(str(e)) except ParseError as e:
except ParseError as e: logger.error('Failed to parse telegram: %s', e)
logger.error('Failed to parse telegram: %s', e)