Avoid long locks in process missedmessage_emails queue.

(imported from commit aed4a89244dce19085ed2ad89a7539ab297d8bc9)
This commit is contained in:
Steve Howell 2013-10-25 20:45:19 -04:00
parent 3cbb9f6b08
commit 13768495a6
1 changed files with 2 additions and 1 deletions

View File

@ -160,6 +160,7 @@ class MissedMessageWorker(QueueProcessingWorker):
by_recipient[event['user_profile_id']].append(event)
for user_profile_id, events in by_recipient.items():
with commit_on_success():
handle_missedmessage_emails(user_profile_id, events)
# Aggregate all messages received every 2 minutes to let someone finish sending a batch