From 7337bcfd37c78655086047f6a03f9db0d6953167 Mon Sep 17 00:00:00 2001 From: Lilit0x Date: Fri, 20 Oct 2023 05:15:48 +0000 Subject: [PATCH] fix: combined datapoints and requests with zip instead of enumerating --- src/servers/src/http/opentsdb.rs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/src/servers/src/http/opentsdb.rs b/src/servers/src/http/opentsdb.rs index 472c55b45466..054595252ad3 100644 --- a/src/servers/src/http/opentsdb.rs +++ b/src/servers/src/http/opentsdb.rs @@ -110,14 +110,11 @@ pub async fn put( }, }; - for (idx, data_point) in data_points.into_iter().enumerate() { + for (data_point, request) in data_points.into_iter().zip(data_point_requests) { let result = opentsdb_handler.exec(vec![data_point], ctx.clone()).await; match result { Ok(affected_rows) => response.on_success(affected_rows), - Err(e) => { - let data_point_request = data_point_requests.get(idx).unwrap(); - response.on_failed(data_point_request.clone(), e); - } + Err(e) => response.on_failed(request, e), } } (