topics-fix
This commit is contained in:
parent
358cc86197
commit
0b8776a87f
|
@ -203,7 +203,7 @@ async def get_authors_with_stat_cached(q):
|
||||||
try:
|
try:
|
||||||
records = []
|
records = []
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
for x in session.execute(q):
|
for [x] in session.execute(q):
|
||||||
stat_str = await redis.execute('GET', f'author:{x.id}')
|
stat_str = await redis.execute('GET', f'author:{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')
|
||||||
|
@ -218,7 +218,7 @@ async def get_topics_with_stat_cached(q):
|
||||||
records = []
|
records = []
|
||||||
current = None
|
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
|
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):
|
||||||
|
|
Loading…
Reference in New Issue
Block a user