aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/table/table.rs7
1 files changed, 2 insertions, 5 deletions
diff --git a/src/table/table.rs b/src/table/table.rs
index 59cfdd07..05a0dab1 100644
--- a/src/table/table.rs
+++ b/src/table/table.rs
@@ -239,9 +239,7 @@ impl<F: TableSchema, R: TableReplication> Table<F, R> {
// Build futures to actually perform each of the corresponding RPC calls
let call_futures = call_list.into_iter().map(|(node, entries)| {
let this = self.clone();
- let tracer = opentelemetry::global::tracer("garage");
- let span = tracer.start(format!("RPC to {:?}", node));
- let fut = async move {
+ async move {
let rpc = TableRpc::<F>::Update(entries);
let resp = this
.system
@@ -254,8 +252,7 @@ impl<F: TableSchema, R: TableReplication> Table<F, R> {
)
.await;
(node, resp)
- };
- fut.with_context(Context::current_with_span(span))
+ }
});
// Run all requests in parallel thanks to FuturesUnordered, and collect results.