From ba781d62244175e2c05645c9adcdcd428a56a460 Mon Sep 17 00:00:00 2001 From: hammadb Date: Fri, 26 Apr 2024 10:42:53 -0700 Subject: [PATCH] merge --- rust/worker/src/execution/orchestration/compact.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/rust/worker/src/execution/orchestration/compact.rs b/rust/worker/src/execution/orchestration/compact.rs index c3ab1121e6e..c7021991bf4 100644 --- a/rust/worker/src/execution/orchestration/compact.rs +++ b/rust/worker/src/execution/orchestration/compact.rs @@ -41,6 +41,7 @@ use std::sync::Arc; use std::time::SystemTime; use std::time::UNIX_EPOCH; use thiserror::Error; +use tracing::Span; use uuid::Uuid; /** The state of the orchestrator. @@ -236,7 +237,7 @@ impl CompactOrchestrator { parition.clone(), ); let task = wrap(operator, input, self_address.clone()); - match self.dispatcher.send(task).await { + match self.dispatcher.send(task, Some(Span::current())).await { Ok(_) => (), Err(e) => { // Log an error and reply to caller @@ -257,7 +258,7 @@ impl CompactOrchestrator { let input = FlushS3Input::new(record_segment_writer, hnsw_segment_writer); let task = wrap(operator, input, self_address); - match self.dispatcher.send(task).await { + match self.dispatcher.send(task, Some(Span::current())).await { Ok(_) => (), Err(e) => { // Log an error and reply to caller