feat: added routing keys for ORA workflow batch update (#33136)

* feat: added routing key for ORA batch update
openedx · Sep 27, 2023 · 512bc40 · 512bc40
1 parent 3b2b2ce
commit 512bc40
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/lms/envs/common.py b/lms/envs/common.py
@@ -3772,6 +3772,7 @@ def _make_locale_paths(settings):  # pylint: disable=missing-function-docstring
 }
 
 ############################ ORA 2 ############################################
+ORA_WORKFLOW_UPDATE_ROUTING_KEY = "edx.lms.core.ora_workflow_update"
 
 # By default, don't use a file prefix
 ORA2_FILE_PREFIX = None

diff --git a/lms/envs/production.py b/lms/envs/production.py
@@ -1078,6 +1078,15 @@ def get_env_setting(setting):
         'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
     'openedx.core.djangoapps.programs.tasks.award_course_certificate': {
         'queue': PROGRAM_CERTIFICATES_ROUTING_KEY},
+    'openassessment.workflow.tasks.update_workflows_for_all_blocked_submissions_task': {
+        'queue': ORA_WORKFLOW_UPDATE_ROUTING_KEY},
+    'openassessment.workflow.tasks.update_workflows_for_course_task': {
+        'queue': ORA_WORKFLOW_UPDATE_ROUTING_KEY},
+    'openassessment.workflow.tasks.update_workflows_for_ora_block_task': {
+        'queue': ORA_WORKFLOW_UPDATE_ROUTING_KEY},
+    'openassessment.workflow.tasks.update_workflow_for_submission_task': {
+        'queue': ORA_WORKFLOW_UPDATE_ROUTING_KEY},
+
 }
 
 LOGO_IMAGE_EXTRA_TEXT = ENV_TOKENS.get('LOGO_IMAGE_EXTRA_TEXT', '')