From 28866ac9c8ab5ba35b362aaba00a2a4d41fd79fc Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Thu, 3 Jul 2025 14:13:00 -0300 Subject: [PATCH] Update logging in DataManager to use debug level for message skipping and insertion confirmation - Changed log level from info to debug for skipping messages to Kafka topic. - Added debug log for successful message insertion into MongoDB collection. --- ingestor/managers/data_manager.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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()