This commit is contained in:
spaced4ndy
2025-11-11 18:09:16 +04:00
parent 171d0ce861
commit 4e39a849f2
+1 -1
View File
@@ -3316,7 +3316,7 @@ runDeliveryJobWorker a deliveryKey Worker {doWork} = do
sendLoop bucketSize cursorGMId_ = do
mems <- withStore' $ \db -> getGroupMembersByCursor db vr user gInfo cursorGMId_ singleSenderGMId_ bucketSize
unless (null mems) $ do
deliver body mems
timeItToView ("deliver, " <> show (length mems) <> " mems") $ deliver body mems
let cursorGMId' = groupMemberId' $ last mems
withStore' $ \db -> updateDeliveryJobCursor db jobId cursorGMId'
unless (length mems < bucketSize) $ sendLoop bucketSize (Just cursorGMId')