diff --git a/.devcontainer/devcontainer.json b/.devcontainer/devcontainer.json index c4d49550c8..00c2bca3c9 100644 --- a/.devcontainer/devcontainer.json +++ b/.devcontainer/devcontainer.json @@ -41,8 +41,7 @@ ] }, "extensions": [ - "rust-lang.rust-analyzer", - "serayuzgur.crates" + "rust-lang.rust-analyzer" ] } }, diff --git a/crates/shared/src/event_handling.rs b/crates/shared/src/event_handling.rs index 9534e513db..79b846d613 100644 --- a/crates/shared/src/event_handling.rs +++ b/crates/shared/src/event_handling.rs @@ -12,6 +12,7 @@ use { futures::{future, Stream, StreamExt, TryStreamExt}, std::sync::Arc, tokio::sync::Mutex, + tracing::Instrument, }; // We expect that there is never a reorg that changes more than the last n @@ -537,7 +538,12 @@ where S: EventStoring + Send + Sync, { async fn run_maintenance(&self) -> Result<()> { - self.lock().await.update_events().await + let mut inner = self.lock().await; + let address = inner.contract.get_events().filter.address; + inner + .update_events() + .instrument(tracing::info_span!("address", ?address)) + .await } fn name(&self) -> &str {