Skip to content

Commit

Permalink
Update queue.py
Browse files Browse the repository at this point in the history
Restore the closing parenthesis
  • Loading branch information
Darsstar authored Aug 28, 2024
1 parent b0a560c commit db55f50
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion aio_pika/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down

0 comments on commit db55f50

Please sign in to comment.