warn the error

FGasper · FGasper · commit 4df1856b0551 · 2024-11-07T10:05:34.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -166,6 +166,10 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 					Err(err).
 					Msg("Failed to finish reading change stream.")
 			} else {
+				verifier.logger.Warn().
+					Err(err).
+					Msg("An error occurred during change stream processing.")
+
 				verifier.changeStreamErrChan <- err
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -166,6 +166,10 @@ func (verifier Verifier) iterateChangeStream(ctx context.Context, cs mongo.Cha`
`166`	`166`	`Err(err).`
`167`	`167`	`Msg("Failed to finish reading change stream.")`
`168`	`168`	`} else {`
	`169`	`+ verifier.logger.Warn().`
	`170`	`+ Err(err).`
	`171`	`+ Msg("An error occurred during change stream processing.")`
	`172`	`+`
`169`	`173`	`verifier.changeStreamErrChan <- err`
`170`	`174`	`}`
`171`	`175`	`}`