ISSUE #78

minos-framework · Feb 10, 2022 · 7c6aaa5 · 7c6aaa5
1 parent 791cd39
commit 7c6aaa5
Show file tree

Hide file tree

Showing 2 changed files with 272 additions and 305 deletions.
diff --git a/minos/api_gateway/discovery/database/client.py b/minos/api_gateway/discovery/database/client.py
@@ -41,7 +41,7 @@ class MinosRedisClient:
 
     __slots__ = "address", "port", "password", "redis"
 
-    def __init__(self, config: MinosConfig, pool_size: int = 2):
+    def __init__(self, config: MinosConfig, pool_size: int = 50):
         """Perform initial configuration and connection to Redis"""
 
         address = config.discovery.database.host
@@ -78,8 +78,9 @@ async def get_all(self) -> list:
         return data
 
     async def set_data(self, key: str, data: dict):
-        await self.redis.set(key, json.dumps(data))
-        await self.redis.close()
+        async with self.redis as r:
+            await r.set(key, json.dumps(data))
+        # await self.redis.save()
 
     async def update_data(self):  # pragma: no cover
         """Update specific value"""