ratelimiter: Fix cleanup

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/src/buildservice/ratelimiter.py b/src/buildservice/ratelimiter.py
index c647744ef7616cd9fd962fa96c388d48c6955636..cf5a68445573f3edcb84d23c316f31a4373663ae 100644 (file)
--- a/src/buildservice/ratelimiter.py
+++ b/src/buildservice/ratelimiter.py
@@ -60,7 +60,7 @@ class RateLimiter(base.Object):
                """
                return RateLimiterRequest(self.backend, *args, **kwargs)
 
-       async def cleanup(backend):
+       async def cleanup(self):
                """
                        Called to cleanup the ratelimiter from expired entries
                """
@@ -69,12 +69,13 @@ class RateLimiter(base.Object):
                        ratelimiter
                        .delete()
                        .where(
-                               ratelimiter.c.expired_at <= sqlalchemy.func.current_timestamp(),
+                               ratelimiter.c.expires_at <= sqlalchemy.func.current_timestamp(),
                        )
                )
 
                # Run the query
-               await self.db.execute(stmt)
+               async with await self.db.transaction():
+                       await self.db.execute(stmt)
 
 
 class RateLimiterRequest(base.Object):