fix(tracing): fix missing new barrier enqueued event (#15216)

risingwavelabs · Feb 23, 2024 · 9c1af73 · 9c1af73
1 parent 2cec344
commit 9c1af73
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/meta/src/barrier/mod.rs b/src/meta/src/barrier/mod.rs
@@ -608,7 +608,9 @@ impl GlobalBarrierManager {
         };
 
         // Tracing related stuff
-        tracing::info!(target: "rw_tracing", parent: prev_epoch.span(), epoch = curr_epoch.value().0, "new barrier enqueued");
+        prev_epoch.span().in_scope(|| {
+            tracing::info!(target: "rw_tracing", epoch = curr_epoch.value().0, "new barrier enqueued");
+        });
         span.record("epoch", curr_epoch.value().0);
 
         let command_ctx = Arc::new(CommandContext::new(