Merge pull request #278 from open-craft/agrendalath/bb-10290-ulmo

chore: add support for Python 3.11 + 3.12 and Django 4.2 + 5.2

Author: Agrendalath

.github/workflows/ci.yml

@@ -25,16 +25,16 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        os: [ubuntu-20.04]
-        python-version: [3.8]
-        toxenv: [py38-django32, quality, docs]
+        os: [ubuntu-latest]
+        python-version: [3.11, 3.12]
+        toxenv: [django42, django52, quality, docs]
 
     steps:
     - name: checkout repo
-      uses: actions/checkout@v3
+      uses: actions/checkout@v5
 
     - name: setup python
-      uses: actions/setup-python@v4
+      uses: actions/setup-python@v6
       with:
         python-version: ${{ matrix.python-version }}
 
@@ -47,7 +47,7 @@ jobs:
       run: tox
 
     - name: Run coverage
-      if: matrix.python-version == '3.8' && matrix.toxenv == 'py38-django32'
+      if: matrix.python-version == '3.11' && matrix.toxenv == 'django42'
       uses: codecov/codecov-action@v3
       with:
         token: ${{ secrets.CODECOV_TOKEN }}

.github/workflows/pypi-publish.yml

@@ -6,16 +6,16 @@ on:
 
 jobs:
   push:
-    runs-on: ubuntu-20.04
+    runs-on: ubuntu-latest
 
     steps:
       - name: Checkout
-        uses: actions/checkout@v3
+        uses: actions/checkout@v5
 
       - name: setup python
-        uses: actions/setup-python@v4
+        uses: actions/setup-python@v6
         with:
-          python-version: 3.8
+          python-version: 3.11
 
       - name: Install Dependencies
         run: pip install -r requirements/pip.txt

CHANGELOG.rst

@@ -14,6 +14,15 @@ Change Log
 Unreleased
 ~~~~~~~~~~
 
+[4.3.0] - 2026-01-28
+~~~~~~~~~~~~~~~~~~~~
+
+* Drop support for Python 2, Python 3.8, and Django 3.2.
+* Add support for Python 3.11 + 3.12 and Django 4.2 + 5.2.
+* Fix the ``stats`` API endpoint.
+* Fix the ``ENROLLMENT_TRACK_UPDATED`` signal.
+* Remove unused compat imports.
+
 [4.2.0] - 2024-06-21
 ~~~~~~~~~~~~~~~~~~~~
 

completion_aggregator/__init__.py

@@ -5,4 +5,4 @@
 
 from __future__ import absolute_import, unicode_literals
 
-__version__ = '4.2.0'
+__version__ = '4.3.0'

completion_aggregator/api/v0/urls.py

@@ -4,18 +4,18 @@
 
 from __future__ import absolute_import, division, print_function, unicode_literals
 
-from django.urls import re_path
+from django.urls import path
 
 from . import views
 
 app_name = 'completion_aggregator'
 
 urlpatterns = [
-    re_path(
-        r'^course/(?P<course_key>.+)/blocks/(?P<block_key>.+)/$',
+    path(
+        'course/<path:course_key>/blocks/<path:block_key>/',
         views.CompletionBlockUpdateView.as_view(),
         name='blockcompletion-update'
     ),
-    re_path(r'^course/$', views.CompletionListView.as_view(), name='aggregator-list'),
-    re_path(r'^course/(?P<course_key>.+)/$', views.CompletionDetailView.as_view(), name='aggregator-detail'),
+    path('course/', views.CompletionListView.as_view(), name='aggregator-list'),
+    path('course/<path:course_key>/', views.CompletionDetailView.as_view(), name='aggregator-detail'),
 ]

completion_aggregator/api/v1/urls.py

@@ -4,14 +4,14 @@
 
 from __future__ import absolute_import, division, print_function, unicode_literals
 
-from django.urls import re_path
+from django.urls import path
 
 from . import views
 
 app_name = 'completion_aggregator'
 
 urlpatterns = [
-    re_path(r'^course/$', views.CompletionListView.as_view()),
-    re_path(r'^course/(?P<course_key>.+)/$', views.CompletionDetailView.as_view()),
-    re_path(r'^stats/(?P<course_key>.+)/$', views.CourseLevelCompletionStatsView.as_view()),
+    path('course/', views.CompletionListView.as_view()),
+    path('course/<path:course_key>/', views.CompletionDetailView.as_view()),
+    path('stats/<path:course_key>/', views.CourseLevelCompletionStatsView.as_view()),
 ]

completion_aggregator/api/v1/views.py

@@ -563,11 +563,16 @@ def get(self, request, course_key):
             course_key=course_key,
             aggregation_name='course',
             user_id__in=[enrollment.user_id for enrollment in enrollments])
-        completion_stats = aggregator_qs.aggregate(
-            possible=Avg('possible'),
-            earned=Sum('earned') / len(enrollments),
-            percent=Sum('earned') / (Avg('possible') * len(enrollments)))
-        completion_stats['course_key'] = course_key
+        num_enrollments = len(enrollments)
+        aggregates = aggregator_qs.aggregate(avg_possible=Avg("possible"), total_earned=Sum("earned"))
+        avg_possible = aggregates["avg_possible"] or 0
+        total_earned = aggregates["total_earned"] or 0
+        completion_stats = {
+            "course_key": course_key,
+            "possible": avg_possible,
+            "earned": total_earned / num_enrollments if num_enrollments else 0,
+            "percent": total_earned / (avg_possible * num_enrollments) if avg_possible and num_enrollments else 0,
+        }
 
         serializer = self.get_serializer_class()(
             instance=completion_stats,

completion_aggregator/batch.py

@@ -11,8 +11,6 @@
 import logging
 import time
 
-import six
-
 from django.conf import settings
 from django.core.cache import cache
 
@@ -79,7 +77,7 @@ def perform_aggregation(batch_size=10000, delay=0.0, limit=None, routing_key=Non
     stale_blocks = collections.defaultdict(set)
     forced_updates = set()
     enqueued = 0
-    for idx in six.moves.range(max_id, min([min_id + batch_size, max_id]) - 1, -1 * batch_size):
+    for idx in range(max_id, min([min_id + batch_size, max_id]) - 1, -1 * batch_size):
         if enqueued >= limit:
             break
         evaluated = stale_queryset.filter(id__gt=idx - batch_size, id__lte=idx)
@@ -108,11 +106,11 @@ def perform_aggregation(batch_size=10000, delay=0.0, limit=None, routing_key=Non
         elif len(stale_blocks[enrollment]) > MAX_KEYS_PER_TASK:
             blocks = []
         else:
-            blocks = [six.text_type(block_key) for block_key in stale_blocks[enrollment]]
+            blocks = [str(block_key) for block_key in stale_blocks[enrollment]]
         aggregation_tasks.update_aggregators.apply_async(
             kwargs={
                 'username': enrollment.username,
-                'course_key': six.text_type(enrollment.course_key),
+                'course_key': str(enrollment.course_key),
                 'block_keys': blocks,
                 'force': enrollment in forced_updates,
             },

completion_aggregator/compat.py

@@ -147,38 +147,3 @@ def get_mobile_only_courses(enrollments):
     course_overview_list = CourseOverview.objects.filter(id__in=course_keys, mobile_available=True)
     filtered_course_overview = [overview.id for overview in course_overview_list]
     return enrollments.filter(course_id__in=filtered_course_overview)
-
-
-def get_course(course_key):
-    """
-    Get course for given key.
-    """
-    from courseware.courses import _get_course  # pylint: disable=import-error
-    return _get_course(course_key)
-
-
-def get_cohorts_for_course(course_key):
-    """
-    Get cohorts for given course key.
-    """
-    from openedx.core.djangoapps.course_groups import cohorts  # pylint: disable=import-error
-    if cohorts.is_course_cohorted(course_key):
-        return cohorts.get_course_cohort_id(course_key)
-    return None
-
-
-def course_access_role_model():
-    """
-    Return the student.models.CourseAccessRole model.
-    """
-    # pragma: no-cover
-    from common.djangoapps.student.models import CourseAccessRole  # pylint: disable=import-error
-    return CourseAccessRole
-
-
-def cohort_membership_model():
-    """
-    Return the course_groups.models.CohortMembership model.
-    """
-    from course_groups.models import CohortMembership  # pylint: disable=import-error
-    return CohortMembership

completion_aggregator/core.py

@@ -12,7 +12,6 @@
 from datetime import datetime
 
 import pytz
-import six
 from xblock.completable import XBlockCompletionMode
 from xblock.core import XBlock
 from xblock.plugin import PluginMissingError
@@ -63,7 +62,7 @@ def set(self, value):
 
         Sets the group to `str(self.course_key)`.
         """
-        group = six.text_type(self.course_key)
+        group = str(self.course_key)
         CacheGroup().set(group, self.cache_key, value, timeout=UPDATER_CACHE_TIMEOUT)
 
     def touch(self):