File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -230,15 +230,9 @@ async def _receive_queue_worker(self):
230230 return
231231 _LOGGER .debug ("Process from receive queue: %s" , response )
232232 if isinstance (response , StickResponse ):
233- try :
234- await self ._notify_stick_response_subscribers (response )
235- except Exception as exc : # [broad-exception-caught]
236- _LOGGER .warning ("Failed to process %s : %s" , response , exc )
233+ await self ._notify_stick_response_subscribers (response )
237234 else :
238- try :
239- await self ._notify_node_response_subscribers (response )
240- except Exception as exc : # [broad-exception-caught]
241- _LOGGER .warning ("Failed to process %s : %s" , response , exc )
235+ await self ._notify_node_response_subscribers (response )
242236 self ._receive_queue .task_done ()
243237 _LOGGER .debug ("Receive_queue_worker stopped" )
244238
You can’t perform that action at this time.
0 commit comments