From 709674ff5e58d5f99c70aeecae700eb64814fd44 Mon Sep 17 00:00:00 2001 From: Paul Masurel Date: Tue, 31 Oct 2023 12:23:26 +0900 Subject: [PATCH] CR comments --- .../scheduling/scheduling_logic.rs | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/quickwit/quickwit-control-plane/src/indexing_scheduler/scheduling/scheduling_logic.rs b/quickwit/quickwit-control-plane/src/indexing_scheduler/scheduling/scheduling_logic.rs index fe682faa466..d03ca46e4f7 100644 --- a/quickwit/quickwit-control-plane/src/indexing_scheduler/scheduling/scheduling_logic.rs +++ b/quickwit/quickwit-control-plane/src/indexing_scheduler/scheduling/scheduling_logic.rs @@ -358,19 +358,6 @@ mod tests { assert_eq!(solution.indexer_assignments[1].num_shards(1), 1); } - #[test] - fn test_truncate_sources() { - let mut problem = SchedulingProblem::with_indexer_maximum_load(vec![5_000, 4_000]); - // Source 0 - problem.add_source(1, NonZeroU32::new(1_000).unwrap()); - let mut solution = problem.new_solution(); - solution.indexer_assignments[0].add_shard(0, 1); - solution.indexer_assignments[0].add_shard(1, 1); - remove_extraneous_shards(&problem, &mut solution); - assert_eq!(solution.indexer_assignments[0].num_shards(0), 1); - assert_eq!(solution.indexer_assignments[0].num_shards(1), 0); - } - #[test] fn test_enforce_nodes_max_load() { let mut problem =