File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -175,16 +175,14 @@ async def _send_queue_worker(self) -> None:
175175 while self ._running and self ._stick is not None :
176176 request = await self ._submit_queue .get ()
177177 _LOGGER .debug ("Sending from send queue %s" , request )
178+ _LOGGER .debug ("HOI queue: %s" , list (self ._submit_queue ._queue ))
178179 if request .priority == Priority .CANCEL :
179180 self ._submit_queue .task_done ()
180181 return
181182
182183 if self ._stick .queue_depth > 3 :
184+ _LOGGER .warning ("Awaiting plugwise responses %d" , self ._stick .queue_depth )
183185 await sleep (0.125 )
184- if self ._stick .queue_depth > 3 :
185- _LOGGER .warning (
186- "Awaiting plugwise responses %d" , self ._stick .queue_depth
187- )
188186
189187 await self ._stick .write_to_stick (request )
190188 self ._submit_queue .task_done ()
You can’t perform that action at this time.
0 commit comments