diff --git a/aio_pika/queue.py b/aio_pika/queue.py index bb61761c..dce0a6e7 100644 --- a/aio_pika/queue.py +++ b/aio_pika/queue.py @@ -468,7 +468,7 @@ async def _on_close( "Message %r lost when queue iterator %r channel closed", msg, self - + ) elif self._consume_kwargs.get("no_ack", False): log.warning( "Message %r lost for consumer with no_ack %r",