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

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

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

8
cache/cache.py vendored
View File

@ -151,12 +151,12 @@ 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_ids = json.loads(cached)
logger.debug(f"Cached followers for topic #{topic_id}: {len(followers)}") logger.debug(f"Cached {len(followers_ids)} followers for topic #{topic_id}")
followers = await get_cached_authors_by_ids(followers_ids)
logger.debug(followers) logger.debug(followers)
return followers return 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(
@ -175,7 +175,7 @@ async def get_cached_topic_followers(topic_id: int):
logger.debug(followers) logger.debug(followers)
return followers return followers
except Exception as e: except Exception as e:
logger.error(f"Ошибка при получении подписчиков для темы#{topic_id}: {str(e)}") logger.error(f"Ошибка при получении подписчиков для темы #{topic_id}: {str(e)}")
return [] return []