diff --git a/diracx-tasks/src/diracx/tasks/plumbing/broker/redis_streams.py b/diracx-tasks/src/diracx/tasks/plumbing/broker/redis_streams.py index 5a8b9d253..e1d6ba2bd 100644 --- a/diracx-tasks/src/diracx/tasks/plumbing/broker/redis_streams.py +++ b/diracx-tasks/src/diracx/tasks/plumbing/broker/redis_streams.py @@ -213,7 +213,7 @@ async def listen(self) -> AsyncGenerator[ReceivedMessage, None]: if pending[1]: logger.info( - "Reclaimed %d unacked messages from %s (message ids: %s)", + "Reclaimed %d unacked messages from %s (message-ids: %s)", len(pending[1]), sname, [msg_id for msg_id, msg in pending[1]],