diff --git a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
index 52d5626e..40f33a79 100644
--- a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
+++ b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/rosbag_processor.py
@@ -72,7 +72,7 @@ def process_rosbag(self,rosbag2_path):
         measurement_name = Path(rosbag2_path).stem # Measurement name is rosbag name without mcap extension
         rosbag2_name = Path(rosbag2_path).name
 
-        self.config.logger.info(f"rosbag name: {rosbag2_name}")
+        self.config.logger.info(f"Processing rosbag: {rosbag2_name}")
 
         if not Path(rosbag2_path).exists():
             processing_error_msg = f"File not found {rosbag2_path}"
@@ -100,6 +100,7 @@ def process_rosbag(self,rosbag2_path):
                     record = self.create_record_from_msg(msg, measurement_name)
                     # Write record to influx
                     self.write_api.write(bucket=self.config.influx_bucket, org=self.config.influx_org, record=record)
+                    self.config.logger.info(f"Writing to Influxdb: {record}")
 
                 except influxdb.exceptions.InfluxDBClientError as e:
                     self.config.logger.error(f"Error from Influx Client: {(e.message)}")
@@ -118,7 +119,7 @@ def process_rosbag(self,rosbag2_path):
             return ProcessingStatus.ERROR.value, processing_error_msg
 
 
-        self.config.logger.info(f"Completed rosbag processing for {rosbag2_name}")
+        self.config.logger.info(f"Completed rosbag processing for: {rosbag2_name}")
 
         self.is_processing = False