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

debug-topics

Browse Source
This commit is contained in:
Untone 2024-03-12 16:21:28 +03:00
parent 6064f0326a
commit 358cc86197
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
resolvers/stat.py
View File

@ -216,13 +216,16 @@ async def get_authors_with_stat_cached(q):
async def get_topics_with_stat_cached(q): async def get_topics_with_stat_cached(q):
try: try:
records = [] records = []
current = None
with local_session() as session: with local_session() as session:
for x in session.execute(q): for x in session.execute(q):
current = x
stat_str = await redis.execute('GET', f'topic:{x.id}') stat_str = await redis.execute('GET', f'topic:{x.id}')
if isinstance(stat_str, str): if isinstance(stat_str, str):
x.stat = json.loads(stat_str).get('stat') x.stat = json.loads(stat_str).get('stat')
records.append(x) records.append(x)
except Exception as exc: except Exception as exc:
logger.error(current)
raise Exception(exc) raise Exception(exc)
return records return records