[DOP-8664] - updated logs messages in MongoDB.WriteOptions

MobileTeleSystems · Sep 11, 2023 · acd4ac5 · acd4ac5
1 parent 10a13a7
commit acd4ac5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/onetl/connection/db_connection/mongodb/connection.py b/onetl/connection/db_connection/mongodb/connection.py
@@ -506,7 +506,7 @@ def write_df_to_target(
 
         if self._collection_exists(target):
             if write_options.if_exists == MongoDBCollectionExistBehavior.ERROR:
-                raise ValueError("Operation stopped due to MongoDB.WriteOptions(if_exists=...) is set to 'error'.")
+                raise ValueError("Operation stopped due to MongoDB.WriteOptions(if_exists='error')")
             elif write_options.if_exists == MongoDBCollectionExistBehavior.IGNORE:
                 log.info(
                     "|%s| Skip writing to existing collection because of MongoDB.WriteOptions(if_exists='ignore')",

diff --git a/...ion/tests_core_integration/tests_db_writer_integration/test_mongodb_writer_integration.py b/...ion/tests_core_integration/tests_db_writer_integration/test_mongodb_writer_integration.py
@@ -129,7 +129,7 @@ def test_mongodb_writer_if_exists_error(spark, processing, get_schema_table, cap
 
     with pytest.raises(
         ValueError,
-        match=re.escape("Operation stopped due to MongoDB.WriteOptions(if_exists=...) is set to 'error'."),
+        match=re.escape("Operation stopped due to MongoDB.WriteOptions(if_exists='error')"),
     ):
         writer.run(df)