We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5b0945a commit ad6005bCopy full SHA for ad6005b
1 file changed
serverish/messenger/msg_reader.py
@@ -110,7 +110,7 @@ async def read_next(self) -> tuple[dict, dict]:
110
log.warning(f"Consumer has gone, ({datetime.now() - read_start_time}s of pulling) trying to recreate it on {self}")
111
try:
112
await self._reopen()
113
- log.info('Consumer recreated {self}')
+ log.info(f'Consumer recreated {self}')
114
except Exception as e:
115
log.error(f"Error recreating consumer: {e}, but we will keep trying {self}")
116
except nats.errors.TimeoutError:
0 commit comments