Log important beats as info (#547)

This commit is contained in:
Félix Saparelli 2023-03-22 14:23:00 +13:00 committed by GitHub
parent 79b28d0264
commit c166823cb6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 35 additions and 15 deletions

30
Cargo.lock generated
View File

@ -828,7 +828,16 @@ version = "4.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ca3aa72a6f96ea37bbc5aa912f6788242832f75369bdfdadcb0e38423f100059"
dependencies = [
"dirs-sys",
"dirs-sys 0.3.7",
]
[[package]]
name = "dirs"
version = "5.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "dece029acd3353e3a58ac2e3eb3c8d6c35827a892edc6cc4138ef9c33df46ecd"
dependencies = [
"dirs-sys 0.4.0",
]
[[package]]
@ -852,6 +861,17 @@ dependencies = [
"winapi",
]
[[package]]
name = "dirs-sys"
version = "0.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "04414300db88f70d74c5ff54e50f9e1d1737d9a5b90f53fcf2e95ca2a9ab554b"
dependencies = [
"libc",
"redox_users",
"windows-sys 0.45.0",
]
[[package]]
name = "dirs-sys-next"
version = "0.1.2"
@ -1566,7 +1586,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e8ffa5bf0772f9b01de501c035b6b084cf9b8bb07dec41e3afc6a17336a65f47"
dependencies = [
"bitflags",
"dirs",
"dirs 4.0.0",
"gix-path",
"libc",
"windows 0.43.0",
@ -3193,7 +3213,7 @@ version = "0.7.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "da31aef70da0f6352dbcb462683eb4dd2bfad01cf3fc96cf204547b9a839a585"
dependencies = [
"dirs",
"dirs 4.0.0",
"fnv",
"nom 5.1.2",
"phf",
@ -3838,7 +3858,7 @@ dependencies = [
"clap_mangen",
"command-group",
"console-subscriber",
"dirs",
"dirs 5.0.0",
"embed-resource",
"futures",
"humantime",
@ -4149,7 +4169,7 @@ dependencies = [
"async-trait",
"byteorder",
"derivative",
"dirs",
"dirs 4.0.0",
"enumflags2",
"event-listener",
"futures-core",

View File

@ -11,7 +11,7 @@ use tokio::{
sync::{mpsc, watch::Receiver},
time::sleep,
};
use tracing::{debug, error, trace, warn};
use tracing::{debug, error, info, trace, warn};
use crate::{
command::Supervisor,
@ -63,7 +63,7 @@ impl OutcomeWorker {
match this.apply(outcome.clone()).await {
Err(err) => {
if matches!(err, RuntimeError::Exit) {
debug!(%gen, "propagating graceful exit");
info!(%gen, "propagating graceful exit");
} else {
error!(?err, %gen, "outcome applier errored");
}

View File

@ -11,7 +11,7 @@ use tokio::{
},
time::timeout,
};
use tracing::{debug, trace};
use tracing::{debug, info, trace};
use crate::{
error::{CriticalError, RuntimeError},
@ -123,7 +123,7 @@ pub async fn worker(
#[allow(clippy::iter_with_drain)]
let events = Arc::from(set.drain(..).collect::<Vec<_>>().into_boxed_slice());
let action = Action::new(Arc::clone(&events));
debug!(?action, "action constructed");
info!(?action, "action constructed");
debug!("running action handler");
let action_handler = {
@ -143,10 +143,10 @@ pub async fn worker(
}
let outcome = outcome.get().cloned().unwrap_or_default();
debug!(?outcome, "handler finished");
debug!(?outcome, "action handler finished");
let outcome = outcome.resolve(process.is_running().await);
debug!(?outcome, "outcome resolved");
info!(?outcome, "outcome resolved");
OutcomeWorker::spawn(
outcome,

View File

@ -9,7 +9,7 @@ use tokio::{
watch,
},
};
use tracing::{debug, debug_span, error, trace, Span};
use tracing::{debug, debug_span, error, info, trace, Span};
use watchexec_signals::Signal;
use crate::{
@ -320,7 +320,7 @@ async fn spawn_process(
.map_err(|_| RuntimeError::HandlerLockHeld("pre-spawn"))?
.into_inner();
debug!(command=?spawnable, "spawning command");
info!(command=?spawnable, "spawning command");
let (proc, id) = if grouped {
let proc = spawnable
.group_spawn()
@ -329,7 +329,7 @@ async fn spawn_process(
err,
})?;
let id = proc.id().ok_or(RuntimeError::ProcessDeadOnArrival)?;
debug!(pgid=%id, "process group spawned");
info!(pgid=%id, "process group spawned");
(Process::Grouped(proc), id)
} else {
let proc = spawnable.spawn().map_err(|err| RuntimeError::IoError {
@ -337,7 +337,7 @@ async fn spawn_process(
err,
})?;
let id = proc.id().ok_or(RuntimeError::ProcessDeadOnArrival)?;
debug!(pid=%id, "process spawned");
info!(pid=%id, "process spawned");
(Process::Ungrouped(proc), id)
};