Remove instrumenting log level (#7620)

I think this should resolve #7155


This removes the level field from the instrumenting we were doing across a range of functions. The level will now default to the level of the log.
This commit is contained in:
Age Manning
2025-06-20 17:44:59 +10:00
committed by GitHub
parent f67084a571
commit d50924677a
8 changed files with 3 additions and 9 deletions

View File

@@ -406,7 +406,6 @@ pub struct ValidatorMonitor<E: EthSpec> {
impl<E: EthSpec> ValidatorMonitor<E> { impl<E: EthSpec> ValidatorMonitor<E> {
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
name = "validator_monitor", name = "validator_monitor",
skip_all skip_all
)] )]

View File

@@ -114,7 +114,6 @@ impl<T: BeaconChainTypes> SubnetService<T> {
/// Establish the service based on the passed configuration. /// Establish the service based on the passed configuration.
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
fields(service = "subnet_service"), fields(service = "subnet_service"),
name = "subnet_service", name = "subnet_service",
skip_all skip_all

View File

@@ -148,7 +148,6 @@ pub struct BackFillSync<T: BeaconChainTypes> {
impl<T: BeaconChainTypes> BackFillSync<T> { impl<T: BeaconChainTypes> BackFillSync<T> {
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
name = "backfill_sync", name = "backfill_sync",
skip_all skip_all
)] )]

View File

@@ -139,7 +139,6 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
#[cfg(test)] #[cfg(test)]
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
fields(service = "lookup_sync"), fields(service = "lookup_sync"),
name = "lookup_sync", name = "lookup_sync",
skip_all skip_all

View File

@@ -39,7 +39,6 @@ impl<T: BeaconChainTypes> Sampling<T> {
#[cfg(test)] #[cfg(test)]
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
fields(service = "sampling"), fields(service = "sampling"),
name = "sampling", name = "sampling",
skip_all skip_all

View File

@@ -153,7 +153,7 @@ impl<T: BeaconChainTypes> SyncingChain<T> {
} }
/// Check if the chain has peers from which to process batches. /// Check if the chain has peers from which to process batches.
#[instrument(parent = None,level = "info", fields(chain = self.id , service = "range_sync"), skip_all)] #[instrument(parent = None,fields(chain = self.id , service = "range_sync"), skip_all)]
pub fn available_peers(&self) -> usize { pub fn available_peers(&self) -> usize {
self.peers.len() self.peers.len()
} }
@@ -211,7 +211,7 @@ impl<T: BeaconChainTypes> SyncingChain<T> {
/// A block has been received for a batch on this chain. /// A block has been received for a batch on this chain.
/// If the block correctly completes the batch it will be processed if possible. /// If the block correctly completes the batch it will be processed if possible.
#[instrument(parent = None,level = "info", fields(chain = self.id , service = "range_sync"), skip_all)] #[instrument(parent = None, fields(chain = self.id , service = "range_sync"), skip_all)]
pub fn on_block_response( pub fn on_block_response(
&mut self, &mut self,
network: &mut SyncNetworkContext<T>, network: &mut SyncNetworkContext<T>,

View File

@@ -82,7 +82,6 @@ where
T: BeaconChainTypes, T: BeaconChainTypes,
{ {
#[instrument(parent = None, #[instrument(parent = None,
level = "info",
fields(component = "range_sync"), fields(component = "range_sync"),
name = "range_sync", name = "range_sync",
skip_all skip_all

View File

@@ -92,7 +92,7 @@ impl TaskExecutor {
/// This function should only be used during testing. In production, prefer to obtain an /// This function should only be used during testing. In production, prefer to obtain an
/// instance of `Self` via a `environment::RuntimeContext` (see the `lighthouse/environment` /// instance of `Self` via a `environment::RuntimeContext` (see the `lighthouse/environment`
/// crate). /// crate).
#[instrument(parent = None,level = "info", fields(service = service_name), name = "task_executor", skip_all)] #[instrument(parent = None,fields(service = service_name), name = "task_executor", skip_all)]
pub fn new<T: Into<HandleProvider>>( pub fn new<T: Into<HandleProvider>>(
handle: T, handle: T,
exit: async_channel::Receiver<()>, exit: async_channel::Receiver<()>,