We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c8fa3ea commit e065b9eCopy full SHA for e065b9e
1 file changed
plugwise_usb/connection/queue.py
@@ -145,12 +145,11 @@ async def _send_queue_worker(self) -> None:
145
self._submit_queue.task_done()
146
return
147
148
- if self._stick.queue_depth > 3:
+ qsize = self._submit_queue.qsize()
149
+ if qsize > 3:
150
await sleep(0.125)
151
- _LOGGER.warning(
152
- "Awaiting plugwise responses %d", self._stick.queue_depth
153
- )
+ _LOGGER.warning("Awaiting plugwise responses %d", qsize)
154
155
await self._stick.write_to_stick(request)
156
0 commit comments