Replace transaction with pipeline

CHANGELOG.md

@@ -2,14 +2,15 @@
 
 ## 0.1
 
+### 0.1.2
+
+- Use milliseconds instead of seconds as default unit of expiration.
+- Update default_callback, round milliseconds up to nearest second for `Retry-After` value.
+- Access response in the callback.
+- Replace transaction with pipeline.
+
 ### 0.1.1
 
 - Configuring the global default through the FastAPILimiter.init method.
 - Update status to 429 when too many requests.
 - Update default_callback params and add `Retry-After` response header.
-
-### 0.1.2
-
-- Use milliseconds instead of seconds as default unit of expiration.
-- Update default_callback, round milliseconds up to nearest second for `Retry-After` value.
-- Access response in callback.

fastapi_limiter/__init__.py

@@ -1,7 +1,7 @@
+from math import ceil
 from typing import Callable
 
 import aioredis
-from math import ceil
 from fastapi import HTTPException
 from starlette.requests import Request
 from starlette.responses import Response

fastapi_limiter/depends.py

@@ -32,10 +32,10 @@ async def __call__(self, request: Request, response: Response):
         redis = FastAPILimiter.redis
         rate_key = await identifier(request)
         key = FastAPILimiter.prefix + ":" + rate_key
-        p = redis.pipeline()
-        p.incrby(key, 1)
-        p.pttl(key)
-        num, pexpire = await p.execute()
+        tr = redis.multi_exec()
+        tr.incrby(key, 1)
+        tr.pttl(key)
+        num, pexpire = await tr.execute()
         if num == 1:
             await redis.pexpire(key, self.milliseconds)
         if num > self.times: