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,