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

cache-fix-5
All checks were successful
Deploy on push / deploy (push) Successful in 46s
Details

Browse Source
This commit is contained in:
Untone 2024-05-30 20:20:02 +03:00
parent b0637da11d
commit 75dd4120ec
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
services/cache.py
View File

@ -195,13 +195,14 @@ async def get_cached_follower_topics(author_id: int):
if cached and isinstance(cached, str): if cached and isinstance(cached, str):
topics_ids = json.loads(cached) topics_ids = json.loads(cached)
else: else:
topics_ids = ( topics = (
local_session() local_session()
.query(Topic.id) .query(Topic)
.select_from(join(Topic, TopicFollower, Topic.id == TopicFollower.topic)) .select_from(join(Topic, TopicFollower, Topic.id == TopicFollower.topic))
.where(TopicFollower.follower == author_id) .where(TopicFollower.follower == author_id)
.all() .all()
) )
topics_ids = [topic.id for topic in topics]
await redis.execute("SET", rkey, json.dumps(topics_ids)) await redis.execute("SET", rkey, json.dumps(topics_ids))
topics = await get_cached_topics_by_ids(topics_ids) topics = await get_cached_topics_by_ids(topics_ids)