feat: add SES delivery support for course update emails

Author: ajayakkalasetti

openedx/core/djangoapps/ace_common/utils.py

@@ -2,10 +2,18 @@
 Utility functions for edx-ace.
 """
 import logging
+from openedx.features.course_experience import (
+    ENABLE_SES_FOR_COURSEUPDATE,
+)
 
 log = logging.getLogger(__name__)
 
 
+SES_MESSAGE_FLAG_MAP = {
+    'course_update': ENABLE_SES_FOR_COURSEUPDATE,
+}
+
+
 def setup_firebase_app(firebase_credentials, app_name='fcm-app'):
     """
     Returns a Firebase app instance if the Firebase credentials are provided.
@@ -19,3 +27,18 @@ def setup_firebase_app(firebase_credentials, app_name='fcm-app'):
             certificate = firebase_admin.credentials.Certificate(firebase_credentials)
             app = firebase_admin.initialize_app(certificate, name=app_name)
         return app
+
+
+def should_route_to_ses(msg):
+    """
+    Determine whether an ACE message should be routed via SES.
+
+    Routing is controlled by message-specific waffle flags.
+    """
+    flag = SES_MESSAGE_FLAG_MAP.get(msg.name)
+
+    if not flag:
+        return False
+
+    # Environment-level flag (not course-scoped)
+    return flag.is_enabled()

openedx/core/djangoapps/schedules/tasks.py

@@ -12,6 +12,7 @@
 from django.core.exceptions import ValidationError
 from django.db.utils import DatabaseError
 from edx_ace import ace
+from edx_ace.errors import RecoverableChannelDeliveryError
 from edx_ace.message import Message
 from edx_ace.utils.date import deserialize, serialize
 from edx_django_utils.monitoring import (
@@ -23,10 +24,12 @@
 from importlib import import_module
 from opaque_keys.edx.keys import CourseKey
 
+from openedx.core.djangoapps.ace_common.utils import should_route_to_ses
 from openedx.core.djangoapps.content.course_overviews.models import CourseOverview
 from openedx.core.djangoapps.schedules import message_types, resolvers
 from openedx.core.djangoapps.schedules.models import Schedule, ScheduleConfig
 from openedx.core.lib.celery.task_utils import emulate_http_request
+from openedx.features.course_experience import ENABLE_SES_FOR_COURSEUPDATE
 from common.djangoapps.track import segment
 
 LOG = logging.getLogger(__name__)
@@ -283,15 +286,35 @@ def _schedule_send(msg_str, site_id, delivery_config_var, log_prefix):  # lint-a
     if _is_delivery_enabled(site, delivery_config_var, log_prefix):
         msg = Message.from_string(msg_str)
         msg.options['skip_disable_user_policy'] = True
-
         user = User.objects.get(id=msg.recipient.lms_user_id)
         if not user.has_usable_password():
             LOG.info(f'{delivery_config_var} Scheduled email User is disabled {user.username}')
             return
         with emulate_http_request(site=site, user=user):
             _annonate_send_task_for_monitoring(msg)
             LOG.debug('%s: Sending message = %s', log_prefix, msg_str)
-            ace.send(msg)
+            if should_route_to_ses(msg):
+                msg.options.update({
+                    'from_address': settings.LMS_COMM_DEFAULT_FROM_EMAIL,
+                    'override_default_channel': 'django_email',
+                    'transactional': True,
+                })
+
+            try:
+                ace.send(msg)
+            except RecoverableChannelDeliveryError:
+                LOG.warning(
+                    '%s: SES send failed for user %s, raising for retry',
+                    log_prefix,
+                    user.id,
+                )
+                raise
+            LOG.info(
+                '%s: Course Update email for user %s sent via %s',
+                log_prefix,
+                user.id,
+                'SES' if should_route_to_ses(msg) else 'default ACE channel',
+            )
             _track_message_sent(site, user, msg)
 
 

openedx/features/course_experience/__init__.py

@@ -83,6 +83,16 @@
 # .. toggle_tickets: https://openedx.atlassian.net/browse/AA-36
 CALENDAR_SYNC_FLAG = CourseWaffleFlag(f'{WAFFLE_FLAG_NAMESPACE}.calendar_sync', __name__)  # lint-amnesty, pylint: disable=toggle-missing-annotation
 
+# .. toggle_name: course_experience.enable_ses_for_courseupdate
+# .. toggle_implementation: CourseWaffleFlag
+# .. toggle_default: False
+# .. toggle_description: Used to determine whether or not to use AWS SES to send Course Update emails for the course.
+# .. toggle_use_cases: opt_in, temporary
+# .. toggle_creation_date: 2026-01-27
+# .. toggle_target_removal_date: None
+# .. toggle_warning: This temporary feature toggle does not have a target removal date.
+ENABLE_SES_FOR_COURSEUPDATE = CourseWaffleFlag(f'{WAFFLE_FLAG_NAMESPACE}.enable_ses_for_courseupdate', __name__)  # lint-amnesty, pylint: disable=toggle-missing-annotation
+
 
 def course_home_page_title(_course):
     """