paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-01 20:44:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

queue_processors: Log more detailed info when marking messages as read.

Browse Source
This commit is contained in:
Mateusz Mandera
2021-05-26 17:41:52 +02:00
committed by Tim Abbott
parent b22a6447dd
commit 496e744053
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
zerver/worker/queue_processors.py
View File

@@ -830,7 +830,13 @@ class DeferredWorker(QueueProcessingWorker):
user_profile = get_user_profile_by_id(event["user_profile_id"])
for recipient_id in event["stream_recipient_ids"]:
do_mark_stream_messages_as_read(user_profile, recipient_id)
count = do_mark_stream_messages_as_read(user_profile, recipient_id)
logger.info(
"Marked %s messages as read for user %s, stream_recipient_id %s",
count,
user_profile.id,
recipient_id,
)
elif event["type"] == "mark_stream_messages_as_read_for_everyone":
# This event is generated by the stream deactivation code path.
batch_size = 100
@@ -845,6 +851,11 @@ class DeferredWorker(QueueProcessingWorker):
offset += len(messages)
if len(messages) < batch_size:
break
logger.info(
"Marked %s messages as read for all users, stream_recipient_id %s",
offset,
event["stream_recipient_id"],
)
elif event["type"] == "clear_push_device_tokens":
try:
clear_push_device_tokens(event["user_profile_id"])