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 38bbf29 commit d335f3cCopy full SHA for d335f3c
plugwise_usb/connection/queue.py
@@ -146,10 +146,10 @@ async def _send_queue_worker(self) -> None:
146
_LOGGER.debug("Send_queue_worker started")
147
while self._running and self._stick is not None:
148
try:
149
- request = await wait_for(self._submit_queue.get(), timeout = 0.5)
+ request = await wait_for(self._submit_queue.get(), timeout=0.5)
150
except TimeoutError:
151
_LOGGER.debug("No queue-item after 0.5s, doing other work")
152
-
+
153
_LOGGER.debug("Sending from send queue %s", request)
154
if request.priority == Priority.CANCEL:
155
self._submit_queue.task_done()
0 commit comments