diff --git a/openedx/core/djangoapps/credentials/management/commands/notify_credentials.py b/openedx/core/djangoapps/credentials/management/commands/notify_credentials.py index c3a5f5b7365d334435a43f39b7cb95b2e37a975e..f42314bb67142509ef60ddd08be13fb1cdb864b8 100644 --- a/openedx/core/djangoapps/credentials/management/commands/notify_credentials.py +++ b/openedx/core/djangoapps/credentials/management/commands/notify_credentials.py @@ -64,9 +64,10 @@ def paged_query(queryset, delay, page_size): if delay and page: time.sleep(delay) - - for i, item in enumerate(subquery, start=1): - yield page_start + i, item + index = 0 + for item in subquery.iterator(): + index += 1 + yield page_start + index, item class Command(BaseCommand):