refactor: logging level in warning

aneoconsulting · Oct 16, 2024 · f1f6168 · f1f6168
1 parent 25f3765
commit f1f6168
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/Adaptors/MongoDB/src/Common/MongoCollectionProvider.cs b/Adaptors/MongoDB/src/Common/MongoCollectionProvider.cs
@@ -124,9 +124,9 @@ await mongoDatabase.CreateCollectionAsync(model.CollectionName,
         catch (Exception ex)
         {
           lastException = ex;
-          logger.LogDebug(ex,
-                          "Retrying to create Collection {CollectionName}",
-                          model.CollectionName);
+          logger.LogWarning(ex,
+                            "Retrying to create Collection {CollectionName}",
+                            model.CollectionName);
           await Task.Delay(1000 * collectionRetry,
                            cancellationToken)
                     .ConfigureAwait(false);
@@ -171,9 +171,9 @@ await model.InitializeIndexesAsync(session,
       catch (Exception ex)
       {
         lastException = ex;
-        logger.LogDebug(ex,
-                        "Retrying to Initialize indexes for {CollectionName} collection",
-                        model.CollectionName);
+        logger.LogWarning(ex,
+                          "Retrying to Initialize indexes for {CollectionName} collection",
+                          model.CollectionName);
         await Task.Delay(1000 * indexRetry,
                          cancellationToken)
                   .ConfigureAwait(false);
@@ -195,9 +195,9 @@ await model.ShardCollectionAsync(session,
         catch (Exception ex)
         {
           lastException = ex;
-          logger.LogDebug(ex,
-                          "Retrying to shard {CollectionName} collection",
-                          model.CollectionName);
+          logger.LogWarning(ex,
+                            "Retrying to shard {CollectionName} collection",
+                            model.CollectionName);
           await Task.Delay(1000 * indexRetry,
                            cancellationToken)
                     .ConfigureAwait(false);
@@ -218,17 +218,17 @@ await model.InitializeCollectionAsync(session,
       }
       catch (MongoBulkWriteException<TData> e) when (e.WriteErrors.All(error => error.Category == ServerErrorCategory.DuplicateKey))
       {
-        logger.LogDebug(e,
-                        "Values were already present within the collection {CollectionName}",
-                        model.CollectionName);
+        logger.LogWarning(e,
+                          "Values were already present within the collection {CollectionName}",
+                          model.CollectionName);
         break;
       }
       catch (Exception ex)
       {
         lastException = ex;
-        logger.LogDebug(ex,
-                        "Retrying to initialize {CollectionName} collection",
-                        model.CollectionName);
+        logger.LogWarning(ex,
+                          "Retrying to initialize {CollectionName} collection",
+                          model.CollectionName);
         await Task.Delay(1000 * indexRetry,
                          cancellationToken)
                   .ConfigureAwait(false);