From fbbdc0f442738692ded82841c9764b747bf72194 Mon Sep 17 00:00:00 2001 From: Remi Dettai Date: Thu, 29 Aug 2024 15:01:20 +0200 Subject: [PATCH] Disable timeout on waiting commit types --- quickwit/quickwit-ingest/src/ingest_v2/router.rs | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/quickwit/quickwit-ingest/src/ingest_v2/router.rs b/quickwit/quickwit-ingest/src/ingest_v2/router.rs index f403b840479..b999e6e57fb 100644 --- a/quickwit/quickwit-ingest/src/ingest_v2/router.rs +++ b/quickwit/quickwit-ingest/src/ingest_v2/router.rs @@ -606,9 +606,14 @@ impl IngestRouterService for IngestRouter { .try_acquire_many_owned(request_size_bytes as u32) .map_err(|_| IngestV2Error::TooManyRequests(RateLimitingCause::RouterLoadShedding))?; - let ingest_res = self - .ingest_timeout(ingest_request, ingest_request_timeout()) - .await; + let ingest_res = if ingest_request.commit_type() == CommitTypeV2::Auto { + self.ingest_timeout(ingest_request, ingest_request_timeout()) + .await + } else { + Ok(self + .retry_batch_persist(ingest_request, MAX_PERSIST_ATTEMPTS) + .await) + }; update_ingest_metrics(&ingest_res, num_subrequests);