Skip to content

Commit c21b9f5

Browse files
committed
Revert "Prevent WritesOff from hanging when the change stream has failed."
This reverts commit dcfb296.
1 parent dcfb296 commit c21b9f5

File tree

2 files changed

+234
-154
lines changed

2 files changed

+234
-154
lines changed

internal/verifier/check.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -236,9 +236,6 @@ func (verifier *Verifier) CheckDriver(ctx context.Context, filter map[string]any
236236
// paying attention. Also, this should not matter too much because any failures will be
237237
// caught again on the next iteration.
238238
if verifier.writesOff {
239-
verifier.logger.Debug().
240-
Msg("Waiting for change stream to end.")
241-
242239
// It's necessary to wait for the change stream to finish before incrementing the
243240
// generation number, or the last changes will not be checked.
244241
verifier.mux.Unlock()

0 commit comments

Comments
 (0)