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

follower-topics-fix
All checks were successful
Deploy on push / deploy (push) Successful in 1m8s
Details

Browse Source
This commit is contained in:
Untone 2024-05-30 21:29:25 +03:00
parent b3a998fec2
commit 9307fc97fb
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/cache.py
View File

@ -203,14 +203,14 @@ async def get_cached_follower_topics(author_id: int):
topics_ids = [topic.id for topic in topics]
await redis.execute("SET", rkey, json.dumps(topics_ids))
if not topics:
topics_objects = []
topics = []
for topic_id in topics_ids:
topic_str = await redis.execute("GET", f"topic:id:{topic_id}")
if topic_str:
topic = json.loads(topic_str)
if topic and topic not in topics_objects:
topics_objects.append(topic.dict())
if topic and topic not in topics:
topics.append(topic)
logger.debug(f"author#{author_id} cache updated with {len(topics)} topics")
return topics