We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1c83ab3 commit e777156Copy full SHA for e777156
1 file changed
plugwise_usb/connection/queue.py
@@ -174,14 +174,14 @@ async def _send_queue_worker(self) -> None:
174
while self._running and self._stick is not None:
175
request = await self._submit_queue.get()
176
_LOGGER.debug("Sending from send queue %s", request)
177
+ _LOGGER.debug("HOI queue: %s", list(self._submit_queue._queue))
178
if request.priority == Priority.CANCEL:
179
self._submit_queue.task_done()
180
return
181
182
if self._stick.queue_depth > 3:
183
+ _LOGGER.warning("Awaiting plugwise responses %d", self._stick.queue_depth)
184
await sleep(0.125)
- if self._stick.queue_depth > 3:
- _LOGGER.warning("Awaiting plugwise responses %d", self._stick.queue_depth)
185
186
await self._stick.write_to_stick(request)
187
0 commit comments