We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f67a345 commit 23b01eaCopy full SHA for 23b01ea
1 file changed
receptor/buffers/file.py
@@ -120,7 +120,7 @@ async def expire(self):
120
item = await self.q.get()
121
ident = item["ident"]
122
expire_time = item["expire_time"]
123
- if expire_time > datetime.datetime.utcnow():
+ if expire_time < datetime.datetime.utcnow():
124
logger.info("Expiring message %s", ident)
125
# TODO: Do something with expired message
126
await self._loop.run_in_executor(pool, os.remove, self._path_for_ident(ident))
0 commit comments