Mirror
/
zulip
mirror of https://github.com/zulip/zulip.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

queue workers: Use self.queue_name in retry_event calls. 

This just adds a bit of robustness if we ever end up renaming queues.
This commit is contained in:
Tim Abbott 2019-12-04 10:08:48 -08:00
parent 2b6cfbcf7b
commit 1465628c95
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zerver/worker/queue_processors.py
View File

@ -206,7 +206,7 @@ class SignupWorker(QueueProcessingWorker):
logging.warning("Attempted to sign up already existing email to list: %s" %
(data['email_address'],))
elif r.status_code == 400:
retry_event('signups', data, lambda e: r.raise_for_status())
retry_event(self.queue_name, data, lambda e: r.raise_for_status())
else:
r.raise_for_status()
@ -433,7 +433,7 @@ class PushNotificationsWorker(QueueProcessingWorker): # nocoverage
logger.warning(
"Maximum retries exceeded for trigger:%s event:push_notification" % (
event['user_profile_id'],))
retry_event('missedmessage_mobile_notifications', event, failure_processor)
retry_event(self.queue_name, event, failure_processor)
# We probably could stop running this queue worker at all if ENABLE_FEEDBACK is False
@assign_queue('feedback_messages')
@ -683,7 +683,7 @@ class DeferredWorker(QueueProcessingWorker):
logger.warning(
"Maximum retries exceeded for trigger:%s event:clear_push_device_tokens" % (
event['user_profile_id'],))
retry_event("deferred_work", event, failure_processor)
retry_event(self.queue_name, event, failure_processor)
elif event['type'] == 'realm_export':
start = time.time()
realm = Realm.objects.get(id=event['realm_id'])