We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b26420 commit 2b0a3f8Copy full SHA for 2b0a3f8
internal/verifier/change_stream.go
@@ -198,7 +198,7 @@ func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
198
199
err = verifier.persistChangeStreamResumeToken(ctx, srcChangeStream)
200
if err != nil {
201
- return errors.Wrap(err, "failed to persist change stream resume token")
+ return err
202
}
203
204
csTimestamp, err := extractTimestampFromResumeToken(srcChangeStream.ResumeToken())
0 commit comments