discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

add-fakeredis
All checks were successful
Deploy on push / deploy (push) Successful in 1m19s
Details

Browse Source
This commit is contained in:
Untone 2024-10-14 13:08:43 +03:00
parent 6f6b619c11
commit 8b65c87750
3 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cache/precache.py vendored
View File

@ -77,6 +77,7 @@ async def precache_topics_followers(topic_id: int, session):
async def precache_data(): async def precache_data():
logger.info("precaching...")
try: try:
key = "authorizer_dev" key = "authorizer_dev"
# cache reset # cache reset

1
pyproject.toml
View File

@ -26,6 +26,7 @@ colorlog = "^6.8.2"
[tool.poetry.group.dev.dependencies] [tool.poetry.group.dev.dependencies]
ruff = "^0.4.7" ruff = "^0.4.7"
isort = "^5.13.2" isort = "^5.13.2"
fakeredis = "^2.25.1"
[build-system] [build-system]
requires = ["poetry-core>=1.0.0"] requires = ["poetry-core>=1.0.0"]

10
services/redis.py
View File

@ -1,8 +1,9 @@
import logging import logging
import redis.asyncio as aredis from fakeredis.aioredis import FakeRedis
from redis.asyncio import Redis
from settings import REDIS_URL from settings import MODE, REDIS_URL
# Set redis logging level to suppress DEBUG messages # Set redis logging level to suppress DEBUG messages
logger = logging.getLogger("redis") logger = logging.getLogger("redis")
@ -16,7 +17,10 @@ class RedisService:
self._client = None self._client = None
async def connect(self): async def connect(self):
self._client = aredis.Redis.from_url(self._uri, decode_responses=True) if MODE == "development":
self._client = FakeRedis(decode_responses=True)
else:
self._client = await Redis.from_url(self._uri, decode_responses=True)
async def disconnect(self): async def disconnect(self):
if self._client: if self._client: