File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed
Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -346,9 +346,7 @@ def remove_subscription_for_responses() -> None:
346346 )
347347 return remove_subscription_for_responses
348348
349- async def _notify_stick_subscribers (
350- self , stick_response : StickResponse
351- ) -> None :
349+ async def _notify_stick_subscribers (self , stick_response : StickResponse ) -> None :
352350 """Call callback for all stick response message subscribers."""
353351 await self ._stick_subscription_lock .acquire ()
354352 for subscription in self ._stick_subscribers_for_requests .values ():
@@ -379,9 +377,9 @@ async def _notify_stick_subscribers(
379377 continue
380378 _LOGGER .debug ("Notify stick response subscriber for %s" , stick_response )
381379 await subscription .callback_fn (stick_response )
382- _LOGGER .debug ("Finished Notify stick response subscriber for %s" , stick_response )
383-
384-
380+ _LOGGER .debug (
381+ "Finished Notify stick response subscriber for %s" , stick_response
382+ )
385383
386384 # endregion
387385 # region node
@@ -501,4 +499,5 @@ async def _notify_node_response_subscribers(
501499 name = f"Postpone subscription task for { node_response .seq_id !r} retry { node_response .retries } " ,
502500 )
503501
502+
504503# endregion
You can’t perform that action at this time.
0 commit comments