Andal.LND/edx-platform
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #27737 from edx/tuchfarber/fix_program_explicit_queue

Browse Source 
fix: remap explicit queues for program tasks
This commit is contained in:
Matt Tuchfarber
2021-05-27 11:01:11 -04:00
committed by GitHub
parent 5986de0d0a e4d3c1a59b
commit b6fe11ea43
2 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
lms/envs/production.py
View File

@@ -1030,13 +1030,13 @@ EXPLICIT_QUEUES = {
'queue': POLICY_CHANGE_GRADES_ROUTING_KEY},
'lms.djangoapps.grades.tasks.recalculate_subsection_grade_v3': {
'queue': RECALCULATE_GRADES_ROUTING_KEY},
'openedx.core.djangoapps.programs.tasks.v1.tasks.award_program_certificates': {
'openedx.core.djangoapps.programs.tasks.award_program_certificates': {
'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
'openedx.core.djangoapps.programs.tasks.v1.tasks.revoke_program_certificates': {
'openedx.core.djangoapps.programs.tasks.revoke_program_certificates': {
'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
'openedx.core.djangoapps.programs.tasks.v1.tasks.update_certificate_visible_date_on_course_update': {
'openedx.core.djangoapps.programs.tasks.update_certificate_visible_date_on_course_update': {
'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
'openedx.core.djangoapps.programs.tasks.v1.tasks.award_course_certificate': {
'openedx.core.djangoapps.programs.tasks.award_course_certificate': {
'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
'openedx.core.djangoapps.coursegraph.dump_course_to_neo4j': {
'queue': COURSEGRAPH_JOB_QUEUE},

12
openedx/core/djangoapps/programs/tasks.py
View File

@@ -137,6 +137,9 @@ def award_program_certificates(self, username): # lint-amnesty, pylint: disable
change - for example, to backpopulate missing program credentials for a
student.
If this function is moved, make sure to update it's entry in
EXPLICIT_QUEUES in the settings files so it runs in the correct queue.
Args:
username (str): The username of the student
@@ -364,6 +367,9 @@ def award_course_certificate(self, username, course_run_key, certificate_availab
This task is designed to be called whenever a student GeneratedCertificate is updated.
It can be called independently for a username and a course_run, but is invoked on each GeneratedCertificate.save.
If this function is moved, make sure to update it's entry in
EXPLICIT_QUEUES in the settings files so it runs in the correct queue.
Arguments:
username (str): The user to award the Credentials course cert to
course_run_key (str): The course run key to award the certificate for
@@ -524,6 +530,9 @@ def revoke_program_certificates(self, username, course_key): # lint-amnesty, py
specified user's certificate should be revoked in one or more programs, and
use the credentials service to revoke the said certificates if so.
If this function is moved, make sure to update it's entry in
EXPLICIT_QUEUES in the settings files so it runs in the correct queue.
Args:
username (str): The username of the student
course_key (str): The course identifier
@@ -674,6 +683,9 @@ def update_certificate_visible_date_on_course_update(self, course_key, certifica
the credentials API to update all these certificates visible_date value
to keep certificates in sync on both sides.
If this function is moved, make sure to update it's entry in
EXPLICIT_QUEUES in the settings files so it runs in the correct queue.
Arguments:
course_key (str): The course identifier
certificate_available_date (str): The date to update the certificate availablity date to. It's a string