raise warning to error

This commit is contained in:
Bryan Stitt 2023-07-07 12:27:20 -07:00
parent f6fea1541b
commit f49a64e551

View File

@ -11,7 +11,7 @@ use migration::sea_orm::DatabaseConnection;
use std::time::Duration; use std::time::Duration;
use tokio::sync::{broadcast, oneshot}; use tokio::sync::{broadcast, oneshot};
use tokio::time::{interval, sleep}; use tokio::time::{interval, sleep};
use tracing::{error, info, trace, warn}; use tracing::{error, info, trace};
#[derive(Debug, Default)] #[derive(Debug, Default)]
pub struct BufferedRpcQueryStats { pub struct BufferedRpcQueryStats {
@ -175,11 +175,11 @@ impl StatBuffer {
} }
if let Err(err) = x.send((tsdb_count, relational_count)) { if let Err(err) = x.send((tsdb_count, relational_count)) {
warn!(%tsdb_count, %relational_count, ?err, "unable to notify about flushed stats"); error!(%tsdb_count, %relational_count, ?err, "unable to notify about flushed stats");
} }
} }
Err(err) => { Err(err) => {
warn!(?err, "unable to flush stat buffer!"); error!(?err, "unable to flush stat buffer!");
} }
} }
} }