reaction-fix
This commit is contained in:
parent
deec1c8181
commit
8266f77a0b
|
@ -229,12 +229,15 @@ async def load_reactions_by(_, _info, by, limit=50, offset=0):
|
||||||
|
|
||||||
CreatedByUser = aliased(User)
|
CreatedByUser = aliased(User)
|
||||||
ReactedShout = aliased(Shout)
|
ReactedShout = aliased(Shout)
|
||||||
|
RepliedReaction = aliased(Reaction)
|
||||||
q = select(
|
q = select(
|
||||||
Reaction, CreatedByUser, ReactedShout
|
Reaction, CreatedByUser, ReactedShout
|
||||||
).join(
|
).join(
|
||||||
CreatedByUser, Reaction.createdBy == CreatedByUser.slug
|
CreatedByUser, Reaction.createdBy == CreatedByUser.slug
|
||||||
).join(
|
).join(
|
||||||
ReactedShout, Reaction.shout == ReactedShout.slug
|
ReactedShout, Reaction.shout == ReactedShout.slug
|
||||||
|
).join(
|
||||||
|
RepliedReaction, Reaction.replyTo == RepliedReaction.id
|
||||||
)
|
)
|
||||||
|
|
||||||
if by.get("shout"):
|
if by.get("shout"):
|
||||||
|
|
|
@ -184,7 +184,7 @@ class ViewedStorage:
|
||||||
failed = 0
|
failed = 0
|
||||||
except Exception:
|
except Exception:
|
||||||
failed += 1
|
failed += 1
|
||||||
print("[stat.viewed] ⎪ update failed #%d, wait 10 seconds" % failed)
|
print("[stat.viewed] ⎩ update failed #%d, wait 10 seconds" % failed)
|
||||||
if failed > 3:
|
if failed > 3:
|
||||||
print("[stat.viewed] ⎩ not trying to update anymore")
|
print("[stat.viewed] ⎩ not trying to update anymore")
|
||||||
break
|
break
|
||||||
|
@ -197,4 +197,4 @@ class ViewedStorage:
|
||||||
await asyncio.sleep(self.period)
|
await asyncio.sleep(self.period)
|
||||||
else:
|
else:
|
||||||
await asyncio.sleep(10)
|
await asyncio.sleep(10)
|
||||||
print("[stat.viewed] ⎪ trying to update data again...")
|
print("[stat.viewed] ⎧ trying to update data again...")
|
||||||
|
|
Loading…
Reference in New Issue
Block a user