From 1b39673c5edd0f882b0786dcba89d16e5f9d3f12 Mon Sep 17 00:00:00 2001 From: Felipe Gasper Date: Wed, 4 Dec 2024 16:07:54 -0500 Subject: [PATCH] =?UTF-8?q?Retry=20=E2=80=9CCursorKilled=E2=80=9D=20when?= =?UTF-8?q?=20iterating=20documents.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/verifier/compare.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/verifier/compare.go b/internal/verifier/compare.go index 2045f4a1..93234fc7 100644 --- a/internal/verifier/compare.go +++ b/internal/verifier/compare.go @@ -7,6 +7,7 @@ import ( "github.com/10gen/migration-verifier/internal/retry" "github.com/10gen/migration-verifier/internal/types" + "github.com/10gen/migration-verifier/internal/util" "github.com/pkg/errors" "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/mongo" @@ -38,6 +39,7 @@ func (verifier *Verifier) FetchAndCompareDocuments( WithBefore(func() { srcChannel, dstChannel, readSrcCallback, readDstCallback = verifier.getFetcherChannelsAndCallbacks(task) }). + WithErrorCodes(util.CursorKilled). Run( givenCtx, verifier.logger,