diff --git a/LTA/LTAIngest/LTAIngestClient/lib/ingestbuslistener.py b/LTA/LTAIngest/LTAIngestClient/lib/ingestbuslistener.py
index 8bc532fcf57eef1aa085d28b3fe97e1530a40455..cea0c28b64eb0354ec60046cca94e46bbc155fc7 100644
--- a/LTA/LTAIngest/LTAIngestClient/lib/ingestbuslistener.py
+++ b/LTA/LTAIngest/LTAIngestClient/lib/ingestbuslistener.py
@@ -111,14 +111,10 @@ class IngestEventMessageHandler(AbstractMessageHandler):
 
     def _log_job_notification(self, status: str, job_dict: dict):
         try:
-            msg = ''
-
-            if status == 'JobProgress':
-                msg += 'job is transferring. '
-            elif status == 'TransferServiceStatus':
-                msg += 'TransferServiceStatus: '
+            if status in ['JobProgress', 'TransferServiceStatus', 'TaskProgress', 'TaskFinished']:
+                msg = "ingest %s " % status
             else:
-                msg += 'job status changed to %s. ' % (status,)
+                msg = 'ingest job status changed to %s. ' % (status,)
 
             msg += 'project: %s export_id: %s type: %s server: %s' % (job_dict.get('project'),
                                                                       job_dict.get('export_id'),