Skip to content

Commit c003289

Browse files
committed
BUG FIX: batching of rechecks
1 parent 6f81c0c commit c003289

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/verifier/recheck.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ func (verifier *Verifier) insertRecheckDocs(
118118
mongo.NewInsertOneModel().SetDocument(recheckDoc),
119119
)
120120
curBatchSize += len(recheckRaw)
121-
if curBatchSize > recheckBatchByteLimit || len(recheckRaw) >= recheckBatchCountLimit {
121+
if curBatchSize > recheckBatchByteLimit || len(curRechecks) >= recheckBatchCountLimit {
122122
recheckBatches = append(recheckBatches, curRechecks)
123123
curRechecks = nil
124124
curBatchSize = 0

0 commit comments

Comments
 (0)