Fixed MongoDB reading input

Luishfs · Luishfs · commit d96ac6fd9602 · 2024-02-23T13:44:30.000-03:00
diff --git a/mage_integrations/mage_integrations/destinations/mongodb/target_mongodb/sinks.py b/mage_integrations/mage_integrations/destinations/mongodb/target_mongodb/sinks.py
@@ -93,7 +93,7 @@ def process_batch(self, context: dict) -> None:
                     try:
                         find_id = ObjectId(find_id)
                     except Exception:
-                        self.logger.warn(f"Malformed id: {find_id}.\
+                        self.logger.info(f"Malformed id: {find_id}.\
                                          Skipping this record.")
                         continue
 
diff --git a/mage_integrations/mage_integrations/destinations/sink.py b/mage_integrations/mage_integrations/destinations/sink.py
@@ -439,7 +439,7 @@ def activate_version(self, new_version: int) -> None:
             new_version: The version number to activate.
         """
         _ = new_version
-        self.logger.warning(
+        self.logger.info(
             "ACTIVATE_VERSION message received but not implemented by this target. "
             "Ignoring.",
         )

Original file line number	Diff line number	Diff line change
`@@ -439,7 +439,7 @@ def activate_version(self, new_version: int) -> None:`
`439`	`439`	`new_version: The version number to activate.`
`440`	`440`	`"""`
`441`	`441`	`_ = new_version`
`442`		`- self.logger.warning(`
	`442`	`+ self.logger.info(`
`443`	`443`	`"ACTIVATE_VERSION message received but not implemented by this target. "`
`444`	`444`	`"Ignoring.",`
`445`	`445`	`)`