Skip to content

Commit

Permalink
removed excessive logging
Browse files Browse the repository at this point in the history
  • Loading branch information
bwsw committed Jan 11, 2025
1 parent e27d5e8 commit 21f7e84
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ serde_json = "1.0"
thiserror = "2"

[workspace.package]
version = "0.4.6"
version = "0.4.7"
edition = "2021"
authors = ["Ivan Kudriavtsev <ivan.a.kudryavtsev@gmail.com>"]
description = "Savant Rust core functions library"
Expand Down
9 changes: 6 additions & 3 deletions savant_core/src/metrics/pipeline_metric_builder.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use crate::metrics::{get_or_create_counter_family, get_or_create_gauge_family};
use crate::rust::FrameProcessingStatRecordType;
use crate::webserver::get_registered_pipelines;
use log::{debug, info};
use log::debug;

#[derive(Debug)]
pub(crate) struct PipelineMetricBuilder;
Expand All @@ -23,14 +23,17 @@ impl PipelineMetricBuilder {
}
}

info!("Building pipeline metrics");
debug!("Building pipeline metrics");
let label_names = ["record_type"].as_slice();
let stage_performance_label_names = ["record_type", "stage_name"].as_slice();
let stage_latency_label_names =
["record_type", "destination_stage_name", "source_stage_name"].as_slice();

let registered_pipelines = get_registered_pipelines().await;
info!("Found {} registered pipelines", registered_pipelines.len());
debug!(
"Found {} registered pipeline(s)",
registered_pipelines.len()
);
for p in registered_pipelines {
let stats = p.get_stat_records(1);
if stats.is_empty() {
Expand Down

0 comments on commit 21f7e84

Please sign in to comment.