Update internal/verifier/change_stream.go

FGasper · tdq45gj · web-flow · commit b3680061095f · 2024-10-31T11:14:16.000-04:00
Co-authored-by: Jian Guan &lt;61915096+tdq45gj@users.noreply.github.com&gt;
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -270,7 +270,7 @@ func (verifier *Verifier) persistChangeStreamResumeToken(ctx context.Context, cs
 		Stringer("resumeToken", token).
 		Msg("Persisted change stream resume token.")
 
-	return errors.Wrapf(err, "failed to persist change stream resume token (%v)", cs.ResumeToken())
+	return errors.Wrapf(err, "failed to persist change stream resume token (%v)", token)
 }
 
 func extractTimestampFromResumeToken(resumeToken bson.Raw) (primitive.Timestamp, error) {

Original file line number	Diff line number	Diff line change
`@@ -270,7 +270,7 @@ func (verifier *Verifier) persistChangeStreamResumeToken(ctx context.Context, cs`
`270`	`270`	`Stringer("resumeToken", token).`
`271`	`271`	`Msg("Persisted change stream resume token.")`
`272`	`272`
`273`		`- return errors.Wrapf(err, "failed to persist change stream resume token (%v)", cs.ResumeToken())`
	`273`	`+ return errors.Wrapf(err, "failed to persist change stream resume token (%v)", token)`
`274`	`274`	`}`
`275`	`275`
`276`	`276`	`func extractTimestampFromResumeToken(resumeToken bson.Raw) (primitive.Timestamp, error) {`