diff --git a/lms/envs/aws.py b/lms/envs/aws.py index 932550d6c2..d828f4d69c 100644 --- a/lms/envs/aws.py +++ b/lms/envs/aws.py @@ -917,9 +917,6 @@ if ENV_TOKENS.get('AUDIT_CERT_CUTOFF_DATE', None): CREDENTIALS_GENERATION_ROUTING_KEY = ENV_TOKENS.get('CREDENTIALS_GENERATION_ROUTING_KEY', DEFAULT_PRIORITY_QUEUE) -# Queue to use for award program certificates -PROGRAM_CERTIFICATES_ROUTING_KEY = ENV_TOKENS.get('PROGRAM_CERTIFICATES_ROUTING_KEY', DEFAULT_PRIORITY_QUEUE) - # The extended StudentModule history table if FEATURES.get('ENABLE_CSMH_EXTENDED'): INSTALLED_APPS.append('coursewarehistoryextended') diff --git a/lms/envs/common.py b/lms/envs/common.py index e7b45fda06..a8d2bb6010 100644 --- a/lms/envs/common.py +++ b/lms/envs/common.py @@ -3237,9 +3237,6 @@ AUDIT_CERT_CUTOFF_DATE = None CREDENTIALS_SERVICE_USERNAME = 'credentials_service_user' CREDENTIALS_GENERATION_ROUTING_KEY = DEFAULT_PRIORITY_QUEUE -# Queue to use for award program certificates -PROGRAM_CERTIFICATES_ROUTING_KEY = DEFAULT_PRIORITY_QUEUE - # Settings for Comprehensive Theming app # See https://github.com/edx/edx-django-sites-extensions for more info diff --git a/lms/envs/production.py b/lms/envs/production.py index 240c57a703..ed98d50517 100644 --- a/lms/envs/production.py +++ b/lms/envs/production.py @@ -914,9 +914,6 @@ if ENV_TOKENS.get('AUDIT_CERT_CUTOFF_DATE', None): CREDENTIALS_GENERATION_ROUTING_KEY = ENV_TOKENS.get('CREDENTIALS_GENERATION_ROUTING_KEY', DEFAULT_PRIORITY_QUEUE) -# Queue to use for award program certificates -PROGRAM_CERTIFICATES_ROUTING_KEY = ENV_TOKENS.get('PROGRAM_CERTIFICATES_ROUTING_KEY', DEFAULT_PRIORITY_QUEUE) - # The extended StudentModule history table if FEATURES.get('ENABLE_CSMH_EXTENDED'): INSTALLED_APPS.append('coursewarehistoryextended') diff --git a/openedx/core/djangoapps/programs/tasks/v1/tasks.py b/openedx/core/djangoapps/programs/tasks/v1/tasks.py index 45e25c8093..5b8fb3e7d0 100644 --- a/openedx/core/djangoapps/programs/tasks/v1/tasks.py +++ b/openedx/core/djangoapps/programs/tasks/v1/tasks.py @@ -101,7 +101,7 @@ def award_program_certificate(client, username, program_uuid, visible_date): }) -@task(bind=True, ignore_result=True, routing_key=settings.PROGRAM_CERTIFICATES_ROUTING_KEY) +@task(bind=True, ignore_result=True, routing_key=ROUTING_KEY) def award_program_certificates(self, username): """ This task is designed to be called whenever a student's completion status