We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3ce1384 commit db7f11cCopy full SHA for db7f11c
plugwise_usb/connection/queue.py
@@ -16,6 +16,7 @@
16
17
_LOGGER = logging.getLogger(__name__)
18
19
+REPORT_QUEUE_FILLING_UP: Final[int] = 8
20
21
@dataclass
22
class RequestState:
@@ -144,10 +145,10 @@ async def _send_queue_worker(self) -> None:
144
145
return
146
147
qsize = self._submit_queue.qsize()
- if qsize > 3:
148
+ if qsize > REPORT_QUEUE_FILLING_UP:
149
# When the queue size grows, rate-limit the sending of requests to avoid overloading the network
150
await sleep(0.125)
151
152
_LOGGER.warning("Awaiting plugwise responses %d", qsize)
153
154
await self._stick.write_to_stick(request)
0 commit comments