diff --git a/common/djangoapps/entitlements/apps.py b/common/djangoapps/entitlements/apps.py
index 5e748da974..69325e2b7e 100644
--- a/common/djangoapps/entitlements/apps.py
+++ b/common/djangoapps/entitlements/apps.py
@@ -18,3 +18,4 @@ class EntitlementsConfig(AppConfig):
         Connect handlers to signals.
         """
         from . import signals  # pylint: disable=unused-variable
+        from .tasks import expire_old_entitlements
diff --git a/common/djangoapps/entitlements/tasks.py b/common/djangoapps/entitlements/tasks.py
index bbef3aa757..7a70fa635d 100644
--- a/common/djangoapps/entitlements/tasks.py
+++ b/common/djangoapps/entitlements/tasks.py
@@ -42,7 +42,7 @@ def expire_old_entitlements(self, start, end, logid='...'):
 
     # This query could be optimized to return a more narrow set, but at a
     # complexity cost. See bug LEARNER-3451 about improving it.
-    entitlements = CourseEntitlement.objects.filter(expired_at__isnull=True, id__gte=start, id__lt=end)
+    entitlements = CourseEntitlement.objects.filter(expired_at__isnull=True, id__gte=start, id__lte=end)
 
     countdown = 2 ** self.request.retries