Skip to content

Commit 3fd830c

Browse files
Update quickwit/quickwit-control-plane/src/ingest/ingest_controller.rs
Co-authored-by: trinity-1686a <trinity@quickwit.io>
1 parent 9e31b68 commit 3fd830c

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

quickwit/quickwit-control-plane/src/ingest/ingest_controller.rs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1086,15 +1086,12 @@ impl IngestController {
10861086

10871087
let shards_to_move: Vec<Shard> = self.rebalance_compute_shards_to_move(model);
10881088

1089-
if shards_to_move.is_empty() {
1090-
crate::metrics::CONTROL_PLANE_METRICS
1091-
.rebalance_shards
1092-
.set(0);
1093-
return Ok(None);
1094-
}
10951089
crate::metrics::CONTROL_PLANE_METRICS
10961090
.rebalance_shards
10971091
.set(shards_to_move.len() as i64);
1092+
if shards_to_move.is_empty() {
1093+
return Ok(None);
1094+
}
10981095

10991096
let mut per_source_num_shards_to_open: HashMap<SourceUid, usize> = HashMap::new();
11001097

0 commit comments

Comments
 (0)