diff --git a/src/pricing/collector.py b/src/pricing/collector.py
index 6cf41c4..c7daf21 100644
--- a/src/pricing/collector.py
+++ b/src/pricing/collector.py
@@ -163,7 +163,7 @@ def collector(c_type):
 
 # Dynamically Spin up Child process for each type wanting to track
 def collectorMain(c_type):
-    log("== Historical Price Collector ==", 'INFO')
+    log("Starting Historical Price Collector", 'INFO')
 
     collector(c_type)
 
diff --git a/src/utils/jsonLogger.py b/src/utils/jsonLogger.py
index 54377ac..a781145 100644
--- a/src/utils/jsonLogger.py
+++ b/src/utils/jsonLogger.py
@@ -8,10 +8,10 @@ import datetime
 class CustomJsonFormatter(jsonlogger.JsonFormatter):
     def add_fields(self, log_record, record, message_dict):
         super(CustomJsonFormatter, self).add_fields(log_record, record, message_dict)
-        if not log_record.get('timestamp'):
+        if not log_record.get('@timestamp'):
             # this doesn't use record.created, so it is slightly off
             now = datetime.datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S.%fZ')
-            log_record['timestamp'] = now
+            log_record['@timestamp'] = now
         if log_record.get('level'):
             log_record['level'] = log_record['level'].upper()
         else:
@@ -23,7 +23,7 @@ def setup_logging(log_level='INFO'):
     logger.setLevel(log_level)
     logHandler = logging.StreamHandler()
 
-    formatter = CustomJsonFormatter('%(timestamp)s %(level)s %(name)s %(message)s')
+    formatter = CustomJsonFormatter('%(@timestamp)s %(level)s %(name)s %(message)s')
 
     logHandler.setFormatter(formatter)
     logger.addHandler(logHandler)