diff --git a/ptvp35/__init__.py b/ptvp35/__init__.py index 63d816a..bb623d2 100644 --- a/ptvp35/__init__.py +++ b/ptvp35/__init__.py @@ -162,7 +162,7 @@ class DbConnection: await self._dump_buffer() request.set_result(None) else: - await self.__queue.put(DumpRequest(request.future)) + self.__queue.put_nowait(DumpRequest(request.future)) async def _write(self, line: str, request: Request): self.__buffer.write(line)