d1a775d3cd
* Use full LMS imports paths in LMS settings and urls modules * Use full LMS import paths in Studio settings and urls modules * Import from lms.djangoapps.badges instead of badges * Import from lms.djangoapps.branding instead of branding * Import from lms.djangoapps.bulk_email instead of bulk_email * Import from lms.djangoapps.bulk_enroll instead of bulk_enroll * Import from lms.djangoapps.ccx instead of ccx * Import from lms.djangoapps.course_api instead of course_api * Import from lms.djangoapps.course_blocks instead of course_blocks * Import from lms.djangoapps.course_wiki instead of course_wiki * Import from lms.djangoapps.courseware instead of courseware * Import from lms.djangoapps.dashboard instead of dashboard * Import from lms.djangoapps.discussion import discussion * Import from lms.djangoapps.email_marketing instead of email_marketing * Import from lms.djangoapps.experiments instead of experiments * Import from lms.djangoapps.gating instead of gating * Import from lms.djangoapps.grades instead of grades * Import from lms.djangoapps.instructor_analytics instead of instructor_analytics * Import form lms.djangoapps.lms_xblock instead of lms_xblock * Import from lms.djangoapps.lti_provider instead of lti_provider * Import from lms.djangoapps.mobile_api instead of mobile_api * Import from lms.djangoapps.rss_proxy instead of rss_proxy * Import from lms.djangoapps.static_template_view instead of static_template_view * Import from lms.djangoapps.survey instead of survey * Import from lms.djangoapps.verify_student instead of verify_student * Stop suppressing EdxPlatformDeprecatedImportWarnings
67 lines
2.5 KiB
Python
67 lines
2.5 KiB
Python
"""
|
|
This file contains celery tasks related to course content gating.
|
|
"""
|
|
|
|
|
|
import logging
|
|
|
|
import six
|
|
from celery import task
|
|
from django.contrib.auth.models import User
|
|
from opaque_keys.edx.keys import CourseKey, UsageKey
|
|
|
|
from lms.djangoapps.gating import api as gating_api
|
|
from lms.djangoapps.course_blocks.api import get_course_blocks
|
|
from xmodule.modulestore.django import modulestore
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
|
|
@task()
|
|
def task_evaluate_subsection_completion_milestones(course_id, block_id, user_id):
|
|
"""
|
|
Updates users' milestones related to completion of a subsection.
|
|
Args:
|
|
course_id(str): Course id which triggered a completion event
|
|
block_id(str): Id of the completed block
|
|
user_id(int): Id of the user who completed a block
|
|
"""
|
|
store = modulestore()
|
|
course_key = CourseKey.from_string(course_id)
|
|
with store.bulk_operations(course_key):
|
|
course = store.get_course(course_key)
|
|
if not course or not course.enable_subsection_gating:
|
|
log.debug(
|
|
u"Gating: ignoring evaluation of completion milestone because it disabled for course [%s]", course_id
|
|
)
|
|
else:
|
|
try:
|
|
user = User.objects.get(id=user_id)
|
|
course_structure = get_course_blocks(user, store.make_course_usage_key(course_key))
|
|
completed_block_usage_key = UsageKey.from_string(block_id).map_into_course(course.id)
|
|
subsection_block = _get_subsection_of_block(completed_block_usage_key, course_structure)
|
|
subsection = course_structure[subsection_block]
|
|
log.debug(
|
|
u"Gating: Evaluating completion milestone for subsection [%s] and user [%s]",
|
|
six.text_type(subsection.location), user.id
|
|
)
|
|
gating_api.evaluate_prerequisite(course, subsection, user)
|
|
except KeyError:
|
|
log.error(u"Gating: Given prerequisite subsection [%s] not found in course structure", block_id)
|
|
|
|
|
|
def _get_subsection_of_block(usage_key, block_structure):
|
|
"""
|
|
Finds subsection of a block by recursively iterating over its parents
|
|
:param usage_key: key of the block
|
|
:param block_structure: block structure
|
|
:return: sequential block
|
|
"""
|
|
parents = block_structure.get_parents(usage_key)
|
|
if parents:
|
|
for parent_block in parents:
|
|
if parent_block.block_type == 'sequential':
|
|
return parent_block
|
|
else:
|
|
return _get_subsection_of_block(parent_block, block_structure)
|