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

debug-followers
Some checks failed
Deploy on push / deploy (push) Failing after 9s
Details

Browse Source
This commit is contained in:
Untone 2024-08-09 07:22:55 +03:00
parent 1c9f6f30d9
commit 983f25d6d3
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cache/cache.py vendored
View File

@ -152,10 +152,11 @@ async def get_cached_topic_followers(topic_id: int):
cached = await redis.get(f"topic:followers:{topic_id}") cached = await redis.get(f"topic:followers:{topic_id}")
if cached: if cached:
followers = json.loads(cached) followers = json.loads(cached)
logger.debug(f"Cached followers for topic#{topic_id}: {len(followers)}") logger.debug(f"Cached followers for topic #{topic_id}: {len(followers)}")
logger.debug(followers)
return followers return followers
logger.debug("[get_cached_topic_followers] >>>>>>>>>>> ") logger.debug(">>>>>>>>>>> update cache from db ")
# Если данные не найдены в кеше, загрузка из базы данных # Если данные не найдены в кеше, загрузка из базы данных
async with local_session() as session: async with local_session() as session:
result = await session.execute( result = await session.execute(
@ -185,7 +186,7 @@ async def get_cached_author_followers(author_id: int):
if cached: if cached:
followers_ids = json.loads(cached) followers_ids = json.loads(cached)
followers = await get_cached_authors_by_ids(followers_ids) followers = await get_cached_authors_by_ids(followers_ids)
logger.debug(f"Cached followers for author#{author_id}: {len(followers)}") logger.debug(f"Cached followers for author #{author_id}: {len(followers)}")
return followers return followers
# Query database if cache is empty # Query database if cache is empty