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 65e8118 commit d34f158Copy full SHA for d34f158
internal/verifier/migration_verifier.go
@@ -255,7 +255,7 @@ func (verifier *Verifier) WritesOff(ctx context.Context) error {
255
256
verifier.mux.Unlock()
257
258
- // This has to happen under the lock because the change stream
+ // This has to happen outside the lock because the change stream
259
// might be inserting docs into the recheck queue, which happens
260
// under the lock.
261
verifier.changeStreamWritesOffTsChan <- finalTs
0 commit comments