Skip to content

Commit 49689c1

Browse files
committed
Revert "revert change_stream"
This reverts commit 77eaf87.
1 parent 75df85c commit 49689c1

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

internal/verifier/change_stream.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,11 +63,9 @@ func (verifier *Verifier) HandleChangeStreamEvent(ctx context.Context, changeEve
6363
case "replace":
6464
fallthrough
6565
case "update":
66-
/*
67-
if err := verifier.generationEventRecorder.AddEvent(changeEvent); err != nil {
68-
return errors.Wrapf(err, "failed to augment stats with change event: %+v", *changeEvent)
69-
}
70-
*/
66+
if err := verifier.generationEventRecorder.AddEvent(changeEvent); err != nil {
67+
return errors.Wrapf(err, "failed to augment stats with change event: %+v", *changeEvent)
68+
}
7169

7270
return verifier.InsertChangeEventRecheckDoc(ctx, changeEvent)
7371
default:

0 commit comments

Comments
 (0)