Skip to content

Commit f3cbad2

Browse files
committed
store: Reset the end of VidBatcher when changing the size
1 parent 382a92f commit f3cbad2

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

store/postgres/src/vid_batcher.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -237,6 +237,10 @@ impl VidBatcher {
237237

238238
pub(crate) fn set_batch_size(&mut self, size: usize) {
239239
self.batch_size.size = size as i64;
240+
self.end = match &self.ogive {
241+
Some(ogive) => ogive.next_point(self.start, size as usize).unwrap(),
242+
None => self.start + size as i64,
243+
};
240244
}
241245
}
242246

0 commit comments

Comments
 (0)