From 6e088a734fba6d71fbb75e6555897483c5554c84 Mon Sep 17 00:00:00 2001 From: Tyler Cloutier Date: Tue, 27 Feb 2024 18:17:08 -0800 Subject: [PATCH] Added #[tracing::instrument(skip_all)] to add_subscriber --- crates/core/src/subscription/module_subscription_actor.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/crates/core/src/subscription/module_subscription_actor.rs b/crates/core/src/subscription/module_subscription_actor.rs index b3c24990a4a..0ecb7bceae7 100644 --- a/crates/core/src/subscription/module_subscription_actor.rs +++ b/crates/core/src/subscription/module_subscription_actor.rs @@ -38,6 +38,7 @@ impl ModuleSubscriptions { } /// Add a subscriber to the module. NOTE: this function is blocking. + #[tracing::instrument(skip_all)] pub fn add_subscriber(&self, sender: ClientConnectionSender, subscription: Subscribe) -> Result<(), DBError> { let tx = &mut *scopeguard::guard(self.relational_db.begin_tx(), |tx| { let ctx = ExecutionContext::subscribe(self.relational_db.address());