diff --git a/ingestor/managers/data_manager.py b/ingestor/managers/data_manager.py index f1c89dc..6c29ffd 100644 --- a/ingestor/managers/data_manager.py +++ b/ingestor/managers/data_manager.py @@ -178,7 +178,7 @@ class DataManager: ) self.logger.error(trace) else: - self.logger.info(f"Skipping message to topic {topic}: {data}") + self.logger.debug(f"Skipping message to topic {topic}: {data}") try: collection = self.mongo_db[topic] @@ -189,6 +189,8 @@ class DataManager: "inserted_at": datetime.now(timezone.utc), } ) + self.logger.debug( + f"Message inserted into MongoDB collection {topic}: {data}") except Exception as e: trace = traceback.format_exc()