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

temp: add temporary logging for entitlement revocation (#32746)

Browse Source 
* temp: add temporary logging for entitlement revocation
This commit is contained in:
Mohammad Ahtasham ul Hassan
2023-07-14 16:04:17 +05:00
committed by GitHub
parent 5d72ba3518
commit 024096a589
4 changed files with 32 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
common/djangoapps/entitlements/rest_api/v1/views.py
View File

@@ -556,8 +556,16 @@ class SubscriptionsRevokeVerifiedAccessView(APIView):
if course_entitlement.enrollment_course_run is not None:
entitled_course_ids.append(str(course_entitlement.enrollment_course_run.course_id))
log.info('B2C_SUBSCRIPTIONS: Getting course completion status for user %s and entitled_course_ids %s',
user_id,
entitled_course_ids)
awarded_cert_course_ids, is_exception = get_courses_completion_status(user_id, entitled_course_ids)
log.info('B2C_SUBSCRIPTIONS: Got course completion response %s for user %s and entitled_course_ids %s',
awarded_cert_course_ids,
user_id,
entitled_course_ids)
if is_exception:
# Trigger the retry task asynchronously
log.exception('B2C_SUBSCRIPTIONS: Exception occurred while getting course completion status for user %s '
@@ -568,6 +576,11 @@ class SubscriptionsRevokeVerifiedAccessView(APIView):
entitled_course_ids,
user_id))
return
log.info('B2C_SUBSCRIPTIONS: Starting revoke_entitlements_and_downgrade_courses_to_audit for user %s and '
'awarded_cert_course_ids %s and revocable_entitlement_uuids %s',
user_id,
awarded_cert_course_ids,
revocable_entitlement_uuids)
revoke_entitlements_and_downgrade_courses_to_audit(course_entitlements, user_id, awarded_cert_course_ids,
revocable_entitlement_uuids)

5
common/djangoapps/entitlements/tasks.py
View File

@@ -177,6 +177,11 @@ def retry_revoke_subscriptions_verified_access(self, revocable_entitlement_uuids
user_id,
revocable_entitlement_uuids
)
log.info('B2C_SUBSCRIPTIONS: Starting revoke_entitlements_and_downgrade_courses_to_audit for user %s and '
'awarded_cert_course_ids %s and revocable_entitlement_uuids %s from retry task',
user_id,
awarded_cert_course_ids,
revocable_entitlement_uuids)
revoke_entitlements_and_downgrade_courses_to_audit(course_entitlements, user_id, awarded_cert_course_ids,
revocable_entitlement_uuids)
else:

10
common/djangoapps/entitlements/utils.py
View File

@@ -69,9 +69,10 @@ def revoke_entitlements_and_downgrade_courses_to_audit(course_entitlements, user
"""
log.info('B2C_SUBSCRIPTIONS: Starting revoke_entitlements_and_downgrade_courses_to_audit for '
'user: %s and course_entitlements_uuids: %s',
'user: %s, course_entitlements_uuids: %s, awarded_cert_course_ids: %s',
user_id,
revocable_entitlement_uuids)
revocable_entitlement_uuids,
awarded_cert_course_ids)
for course_entitlement in course_entitlements:
if course_entitlement.enrollment_course_run is None:
if course_entitlement.expired_at is None:
@@ -90,6 +91,7 @@ def revoke_entitlements_and_downgrade_courses_to_audit(course_entitlements, user
user_id,
course_id)
log.info('B2C_SUBSCRIPTIONS: Completed revoke_entitlements_and_downgrade_courses_to_audit for '
'user: %s and course_entitlements_uuids %s',
'user: %s, course_entitlements_uuids: %s, awarded_cert_course_ids: %s',
user_id,
revocable_entitlement_uuids)
revocable_entitlement_uuids,
awarded_cert_course_ids)

8
openedx/core/djangoapps/credentials/utils.py
View File

@@ -150,10 +150,18 @@ def get_courses_completion_status(lms_user_id, course_run_ids):
return [], True
# Yes, This is course_credentials_data. The key is named status but
# it contains all the courses data from credentials.
log.info("Course completion status response for lms_user_id [%s] for course_run_ids [%s] is [%s]",
lms_user_id,
course_run_ids,
course_completion_response)
course_credentials_data = course_completion_response.get('status', [])
if course_credentials_data is not None:
filtered_records = [course_data['course_run']['key'] for course_data in course_credentials_data if
course_data['course_run']['key'] in course_run_ids and
course_data['status'] == settings.CREDENTIALS_COURSE_COMPLETION_STATE]
log.info("Filtered course completion status response for lms_user_id [%s] for course_run_ids [%s] is [%s]",
lms_user_id,
course_run_ids,
filtered_records)
return filtered_records, False
return [], False