feat: put step logs in a span (#746)
This commit is contained in:
@@ -34,6 +34,14 @@ impl<'a> Runner<'a> {
|
|||||||
let key = key.into();
|
let key = key.into();
|
||||||
debug!("Step {:?}", key);
|
debug!("Step {:?}", key);
|
||||||
|
|
||||||
|
// alter the `func` to put it in a span
|
||||||
|
let func = || {
|
||||||
|
let span =
|
||||||
|
tracing::span!(parent: tracing::Span::none(), tracing::Level::TRACE, "step", step = ?step, key = %key);
|
||||||
|
let _guard = span.enter();
|
||||||
|
func()
|
||||||
|
};
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
match func() {
|
match func() {
|
||||||
Ok(()) => {
|
Ok(()) => {
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ use std::process::Command;
|
|||||||
use color_eyre::eyre::Result;
|
use color_eyre::eyre::Result;
|
||||||
|
|
||||||
use tracing::{debug, error};
|
use tracing::{debug, error};
|
||||||
use tracing_subscriber::fmt::format::FmtSpan;
|
|
||||||
use tracing_subscriber::layer::SubscriberExt;
|
use tracing_subscriber::layer::SubscriberExt;
|
||||||
use tracing_subscriber::reload::{Handle, Layer};
|
use tracing_subscriber::reload::{Handle, Layer};
|
||||||
use tracing_subscriber::util::SubscriberInitExt;
|
use tracing_subscriber::util::SubscriberInitExt;
|
||||||
@@ -239,10 +238,7 @@ pub fn install_tracing(filter_directives: &str) -> Result<Handle<EnvFilter, Regi
|
|||||||
.or_else(|_| EnvFilter::try_from_default_env())
|
.or_else(|_| EnvFilter::try_from_default_env())
|
||||||
.or_else(|_| EnvFilter::try_new(DEFAULT_LOG_LEVEL))?;
|
.or_else(|_| EnvFilter::try_new(DEFAULT_LOG_LEVEL))?;
|
||||||
|
|
||||||
let fmt_layer = fmt::layer()
|
let fmt_layer = fmt::layer().with_target(false).without_time();
|
||||||
.with_target(false)
|
|
||||||
.with_span_events(FmtSpan::NEW | FmtSpan::CLOSE)
|
|
||||||
.without_time();
|
|
||||||
|
|
||||||
let (filter, reload_handle) = Layer::new(env_filter);
|
let (filter, reload_handle) = Layer::new(env_filter);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user