with limit

tidepool-org · Dec 21, 2023 · a6fb33c · a6fb33c
1 parent 47d16a7
commit a6fb33c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go
@@ -388,6 +388,7 @@ func (m *Migration) fetchAndUpdateBatch() bool {
 		dataSet := []bson.M{}
 		dDataCursor, err := dataC.Find(m.ctx, selector,
 			&options.FindOptions{
+				Limit:     &m.config.readBatchSize,
 				Sort:      bson.M{"_id": 1},
 				BatchSize: &size,
 			},