Skip to content

Commit

Permalink
[consensus][buffer_manager_test][bugfix] count batches properly (#13839)
Browse files Browse the repository at this point in the history
  • Loading branch information
ibalajiarun authored Jun 27, 2024
1 parent 0d92186 commit ba06d09
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions consensus/src/pipeline/tests/buffer_manager_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -255,8 +255,9 @@ async fn assert_results(
batches: Vec<Vec<PipelinedBlock>>,
result_rx: &mut Receiver<OrderedBlocks>,
) {
let total_batches = batches.iter().flatten().count();
let mut blocks: Vec<PipelinedBlock> = Vec::new();
for _ in 0..batches.len() {
while blocks.len() < total_batches {
let OrderedBlocks { ordered_blocks, .. } = result_rx.next().await.unwrap();
blocks.extend(ordered_blocks.into_iter());
}
Expand Down Expand Up @@ -340,7 +341,6 @@ fn buffer_manager_happy_path_test() {
});
}

#[ignore] // TODO: turn this test back on once the flakes have resolved.
#[test]
fn buffer_manager_sync_test() {
// happy path
Expand Down

0 comments on commit ba06d09

Please sign in to comment.