Skip to content

feat: Move Program Certificate event publishing to the monolith #38753

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
rahulkanneri-2u wants to merge 9 commits into
base: master
Choose a base branch
from
+74 −0
Open

feat: Move Program Certificate event publishing to the monolith #38753

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
58f47f3
feat: Move Program Certificate event publishing to the monolith
rahulkanneri-2u May 29, 2026
86c40b7
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 2, 2026
dfe312d
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 4, 2026
8398d2c
fix: Ruff issue fixed
rahulkanneri-2u Jun 5, 2026
eca22cc
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 5, 2026
ddf3067
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 8, 2026
db1a682
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 9, 2026
00b9bc8
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 11, 2026
98658bc
Merge branch 'master' into move-program-certificate-events
rahulkanneri-2u Jun 12, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
30 changes: 30 additions & 0 deletions lms/envs/common.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3218,6 +3218,36 @@ def _should_send_certificate_events(settings):
"enabled": False
},
},
'org.openedx.learning.program.certificate.awarded.v1': {
'learning-program-certificate-lifecycle': {
'event_key_field': 'program_certificate.program.uuid',
# .. toggle_name: EVENT_BUS_PRODUCER_CONFIG['org.openedx.learning.program.certificate.awarded.v1']
# ['learning-program-certificate-lifecycle']['enabled']
# .. toggle_implementation: DjangoSetting
# .. toggle_default: False
# .. toggle_description: Enables sending PROGRAM_CERTIFICATE_AWARDED events over the event bus from
# edx-platform. Disabled until Credentials IDA is ready to consume these events instead of
# receiving REST API calls.
# .. toggle_use_cases: opt_in
# .. toggle_creation_date: 2026-05-26
'enabled': False,
},
},
'org.openedx.learning.program.certificate.revoked.v1': {
'learning-program-certificate-lifecycle': {
'event_key_field': 'program_certificate.program.uuid',
# .. toggle_name: EVENT_BUS_PRODUCER_CONFIG['org.openedx.learning.program.certificate.revoked.v1']
# ['learning-program-certificate-lifecycle']['enabled']
# .. toggle_implementation: DjangoSetting
# .. toggle_default: False
# .. toggle_description: Enables sending PROGRAM_CERTIFICATE_REVOKED events over the event bus from
# edx-platform. Disabled until Credentials IDA is ready to consume these events instead of
# receiving REST API calls.
# .. toggle_use_cases: opt_in
# .. toggle_creation_date: 2026-05-26
'enabled': False,
},
},
})

#### Survey Report ####
Expand Down
44 changes: 44 additions & 0 deletions openedx/core/djangoapps/programs/tasks.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,8 @@
from edx_django_utils.monitoring import set_code_owner_attribute
from opaque_keys import InvalidKeyError
from opaque_keys.edx.keys import CourseKey
from openedx_events.learning.data import ProgramCertificateData, ProgramData, UserData, UserPersonalData
from openedx_events.learning.signals import PROGRAM_CERTIFICATE_AWARDED, PROGRAM_CERTIFICATE_REVOKED
from requests.exceptions import HTTPError

from common.djangoapps.course_modes.models import CourseMode
Expand Down Expand Up @@ -364,6 +366,27 @@ def award_program_certificates(self, username): # pylint: disable=too-many-stat
try:
award_program_certificate(credentials_client, student, program_uuid)
LOGGER.info(f"Awarded program certificate to user {student.id} in program {program_uuid}")
PROGRAM_CERTIFICATE_AWARDED.send_event(
program_certificate=ProgramCertificateData(
user=UserData(
pii=UserPersonalData(
username=student.username,
email=student.email,
name=student.profile.name,
),
id=student.id,
is_active=student.is_active,
),
program=ProgramData(
uuid=program_uuid,
title="",
program_type="",
),
uuid="",
status="awarded",
url="",
)
)
except HTTPError as exc:
if exc.response.status_code == 404:
LOGGER.warning(
Expand Down Expand Up @@ -669,6 +692,27 @@ def revoke_program_certificates(self, username, course_key): # pylint: disable=
try:
revoke_program_certificate(credentials_client, username, program_uuid)
LOGGER.info(f"Revoked program certificate from user {student.id} in program {program_uuid}")
PROGRAM_CERTIFICATE_REVOKED.send_event(
program_certificate=ProgramCertificateData(
user=UserData(
pii=UserPersonalData(
username=student.username,
email=student.email,
name=student.profile.name,
),
id=student.id,
is_active=student.is_active,
),
program=ProgramData(
uuid=program_uuid,
title="",
program_type="",
),
uuid="",
status="revoked",
url="",
)
)
except HTTPError as exc:
if exc.response.status_code == 404:
LOGGER.warning(
Expand Down
Loading