Logging bulk importer job

core/importers/models.py

@@ -2,6 +2,7 @@
 import time
 from datetime import datetime
 
+from celery.utils.log import get_task_logger
 from django.db.models import F
 from ocldev.oclfleximporter import OclFlexImporter
 from pydash import compact
@@ -16,6 +17,8 @@
 from core.sources.models import Source
 from core.users.models import UserProfile
 
+logger = get_task_logger(__name__)
+
 
 class ImportResults:
     def __init__(self, importer):
@@ -468,6 +471,7 @@ def notify_progress(self):
     def run(self):
         for original_item in self.input_list:
             self.processed += 1
+            logger.info('Processing {} of {} | Started at {}'.format(self.processed, self.total, self.start_time))
             self.notify_progress()
             item = original_item.copy()
             item_type = item.pop('type', '').lower()