From 51c2aaf5d52c03d98c3cf0fed72579ed441479c4 Mon Sep 17 00:00:00 2001 From: Anand Kumar Date: Thu, 11 Jan 2024 21:03:26 +0530 Subject: [PATCH 1/2] Added aioredis adapter --- lasier/adapters/caches/__init__.py | 1 + lasier/adapters/caches/aioredis.py | 8 ++++++++ 2 files changed, 9 insertions(+) create mode 100644 lasier/adapters/caches/aioredis.py diff --git a/lasier/adapters/caches/__init__.py b/lasier/adapters/caches/__init__.py index a738a32..48947e0 100644 --- a/lasier/adapters/caches/__init__.py +++ b/lasier/adapters/caches/__init__.py @@ -2,3 +2,4 @@ from .django import Adapter as DjangoAdapter # noqa from .django import AdapterAsync as DjangoAsyncAdapter # noqa from .redis import Adapter as RedisAdapter # noqa +from .aioredis import Adapter as AioRedisAdapter # noqa diff --git a/lasier/adapters/caches/aioredis.py b/lasier/adapters/caches/aioredis.py new file mode 100644 index 0000000..dde59b2 --- /dev/null +++ b/lasier/adapters/caches/aioredis.py @@ -0,0 +1,8 @@ +from lasier.types import Timeout + +from .base import AsyncCacheAdapterBase + + +class Adapter(AsyncCacheAdapterBase): + async def add(self, key: str, value: int, timeout: Timeout = None) -> None: + self.cache.set(key, value, timeout, nx=True) From 1ca6e78a3f7b6fd08e6686e2ec222dfc77649a1b Mon Sep 17 00:00:00 2001 From: Anand Kumar Date: Thu, 11 Jan 2024 21:16:58 +0530 Subject: [PATCH 2/2] code fixes --- lasier/adapters/caches/aioredis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lasier/adapters/caches/aioredis.py b/lasier/adapters/caches/aioredis.py index dde59b2..13a28f1 100644 --- a/lasier/adapters/caches/aioredis.py +++ b/lasier/adapters/caches/aioredis.py @@ -5,4 +5,4 @@ class Adapter(AsyncCacheAdapterBase): async def add(self, key: str, value: int, timeout: Timeout = None) -> None: - self.cache.set(key, value, timeout, nx=True) + await self.cache.set(key, value, timeout, nx=True)