Task #10898: improved log message

LTA/LTAIngest/LTAIngestClient/lib/ingestbuslistener.py

@@ -114,14 +114,19 @@ class IngestBusListener(AbstractBusListener):
         :param task_dict: dictionary with the finished task'''
         pass
 
-
     def _logJobNotification(self, status, job_dict, level=logging.INFO):
-        msg = 'job %s: %s export_id: %s type: %s server: %s'% (status,
-                                                               job_dict.get('project'),
-                                                               job_dict.get('export_id'),
-                                                               job_dict.get('type'),
-                                                               job_dict.get('ingest_server'))
         try:
+            msg = 'job '
+
+            if status == 'progress':
+                msg += 'is transferring. '
+            else:
+                msg += 'status changed to %s. ' % (status,)
+
+            msg += 'project: %s export_id: %s type: %s server: %s'% (job_dict.get('project'),
+                                                                     job_dict.get('export_id'),
+                                                                     job_dict.get('type'),
+                                                                     job_dict.get('ingest_server'))
             if job_dict.get('archive_id'):
                 msg += ' archive_id: %s' % job_dict.get('archive_id')
 
@@ -142,11 +147,11 @@ class IngestBusListener(AbstractBusListener):
 
             if job_dict.get('message'):
                 msg += ' message: %s' % job_dict.get('message')
+
+            logger.log(level, msg)
         except Exception as e:
             logger.error(e)
 
-        logger.log(level, msg)
-
 
 class JobsMonitor(IngestBusListener):
     def __init__(self, busname=DEFAULT_INGEST_NOTIFICATION_BUSNAME, subjects=DEFAULT_INGEST_NOTIFICATION_SUBJECTS, broker=DEFAULT_BROKER, listen_for_all_jobs=True, **kwargs):