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

following-fix-2

Browse Source
This commit is contained in:
Untone 2024-01-23 02:41:37 +03:00
parent 5548d6d1f7
commit f4e8f29fdd
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
services/following.py
View File

@ -39,7 +39,8 @@ class FollowingManager:
async def push(kind, payload): async def push(kind, payload):
try: try:
async with FollowingManager.lock: async with FollowingManager.lock:
for entity in FollowingManager.followers_by_kind.get(kind, []): entities = FollowingManager.followers_by_kind.get(kind, [])
for entity in entities[:]: # Use a copy to iterate
if payload.shout["created_by"] == entity.uid: if payload.shout["created_by"] == entity.uid:
entity.queue.put_nowait(payload) entity.queue.put_nowait(payload)
except Exception as e: except Exception as e: