specify routing / queue for program credentials task.

ECOM-3638
This commit is contained in:
jsa
2016-02-12 12:21:10 -05:00
parent 8a620640c2
commit 46ad8a3399
4 changed files with 12 additions and 1 deletions

View File

@@ -17,6 +17,8 @@ from openedx.core.lib.token_utils import get_id_token
LOGGER = get_task_logger(__name__)
# Under cms the following setting is not defined, leading to errors during tests.
ROUTING_KEY = getattr(settings, 'CREDENTIALS_GENERATION_ROUTING_KEY', None)
def get_api_client(api_config, student):
@@ -115,7 +117,7 @@ def award_program_certificate(client, username, program_id):
})
@task(bind=True, ignore_result=True)
@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