aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-12-11 14:57:42 +0100
committerAlex Auvolat <alex@adnab.me>2023-12-11 14:57:42 +0100
commite4f493b48156e6e30f16fba10f300f6cb5fe0b0d (patch)
treeda06b35bf364405a5d0ff169dccc2215c3bcbf60
parentf8df90b79b93e4a1391839435718bad8c697246d (diff)
downloadgarage-e4f493b48156e6e30f16fba10f300f6cb5fe0b0d.tar.gz
garage-e4f493b48156e6e30f16fba10f300f6cb5fe0b0d.zip
table: remove redundant tracing in insert_many
-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.