Skip to content

Commit b03fe93

Browse files
committed
do not disable queue size metric
1 parent c66fc47 commit b03fe93

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

crates/batcher/src/lib.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1412,10 +1412,9 @@ impl Batcher {
14121412

14131413
// Update metrics
14141414
let queue_len = batch_state_lock.batch_queue.len();
1415-
let queue_size_bytes: i64 = 0;
1416-
// let queue_size_bytes = calculate_batch_size(&batch_state_lock.batch_queue)?;
1415+
let queue_size_bytes = calculate_batch_size(&batch_state_lock.batch_queue)?;
14171416
self.metrics
1418-
.update_queue_metrics(queue_len as i64, queue_size_bytes);
1417+
.update_queue_metrics(queue_len as i64, queue_size_bytes as i64);
14191418

14201419
info!("Current batch queue length: {}", queue_len);
14211420

0 commit comments

Comments
 (0)