diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-12-11 14:57:42 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-12-11 14:57:42 +0100 |
| commit | e4f493b48156e6e30f16fba10f300f6cb5fe0b0d (patch) | |
| tree | da06b35bf364405a5d0ff169dccc2215c3bcbf60 | |
| parent | f8df90b79b93e4a1391839435718bad8c697246d (diff) | |
| download | garage-e4f493b48156e6e30f16fba10f300f6cb5fe0b0d.tar.gz garage-e4f493b48156e6e30f16fba10f300f6cb5fe0b0d.zip | |
table: remove redundant tracing in insert_many
| -rw-r--r-- | src/table/table.rs | 7 |
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. |