File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -271,6 +271,7 @@ async def _put_message_in_queue(
271271 _LOGGER .debug ("Add response to queue: %s" , response )
272272 await self ._message_queue .put (response )
273273 if self ._message_worker_task is None or self ._message_worker_task .done ():
274+ _LOGGER .debug ("Queue: start new worker-task" )
274275 self ._message_worker_task = self ._loop .create_task (
275276 self ._message_queue_worker (),
276277 name = "Plugwise message receiver queue worker" ,
@@ -281,6 +282,7 @@ async def _message_queue_worker(self) -> None:
281282 _LOGGER .debug ("Message queue worker started" )
282283 while self .is_connected :
283284 response : PlugwiseResponse = await self ._message_queue .get ()
285+ _LOGGER .debug ("Priority: %s" , response .priority )
284286 if response .priority == Priority .CANCEL :
285287 self ._message_queue .task_done ()
286288 return
You can’t perform that action at this time.
0 commit comments