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 eb08418 commit b3d78eeCopy full SHA for b3d78ee
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