From 8eb73a6e1720c9218fcdd1f0f8b9e6bad03ff97f Mon Sep 17 00:00:00 2001 From: Waheed Ahmed Date: Thu, 29 Mar 2018 14:39:03 +0500 Subject: [PATCH] Route sailthru tasks to lms ace queue instead of default. LEARNER-4801 --- lms/djangoapps/email_marketing/tasks.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/lms/djangoapps/email_marketing/tasks.py b/lms/djangoapps/email_marketing/tasks.py index 0e78e11b61..2ff915191d 100644 --- a/lms/djangoapps/email_marketing/tasks.py +++ b/lms/djangoapps/email_marketing/tasks.py @@ -15,9 +15,10 @@ from email_marketing.models import EmailMarketingConfiguration log = logging.getLogger(__name__) SAILTHRU_LIST_CACHE_KEY = "email.marketing.cache" +ACE_ROUTING_KEY = getattr(settings, 'ACE_ROUTING_KEY', None) -@task(bind=True) +@task(bind=True, routing_key=ACE_ROUTING_KEY) def get_email_cookies_via_sailthru(self, user_email, post_parms): """ Adds/updates Sailthru cookie information for a new user. @@ -58,7 +59,7 @@ def get_email_cookies_via_sailthru(self, user_email, post_parms): # pylint: disable=not-callable -@task(bind=True, default_retry_delay=3600, max_retries=24) +@task(bind=True, default_retry_delay=3600, max_retries=24, routing_key=ACE_ROUTING_KEY) def update_user(self, sailthru_vars, email, site=None, new_user=False, send_welcome_email=False): """ Adds/updates Sailthru profile information for a user. @@ -134,7 +135,7 @@ def is_default_site(site): # pylint: disable=not-callable -@task(bind=True, default_retry_delay=3600, max_retries=24) +@task(bind=True, default_retry_delay=3600, max_retries=24, routing_key=ACE_ROUTING_KEY) def update_user_email(self, new_email, old_email): """ Adds/updates Sailthru when a user email address is changed @@ -294,7 +295,7 @@ def _retryable_sailthru_error(error): return code == 9 or code == 43 -@task(bind=True) +@task(bind=True, routing_key=ACE_ROUTING_KEY) def update_course_enrollment(self, email, course_key, mode): """Adds/updates Sailthru when a user adds to cart/purchases/upgrades a course Args: