Remove outter timeouts

quickwit/quickwit-serve/src/elasticsearch_api/bulk_v2.rs

@@ -18,7 +18,7 @@
 // along with this program. If not, see <http://www.gnu.org/licenses/>.
 
 use std::collections::HashMap;
-use std::time::{Duration, Instant};
+use std::time::Instant;
 
 use hyper::StatusCode;
 use quickwit_config::INGEST_V2_SOURCE_ID;
@@ -130,9 +130,7 @@ pub(crate) async fn elastic_bulk_ingest_v2(
     let Some(ingest_request) = ingest_request_opt else {
         return Ok(ElasticBulkResponse::default());
     };
-    let ingest_response_v2 =
-        tokio::time::timeout(Duration::from_millis(500), ingest_router.ingest(ingest_request)).await
-            .map_err(|err| ElasticsearchError::new(StatusCode::REQUEST_TIMEOUT, "router timeout".to_string(), None))??;
+    let ingest_response_v2 = ingest_router.ingest(ingest_request).await?;
     let errors = !ingest_response_v2.failures.is_empty();
     let mut items = Vec::new();
 

quickwit/quickwit-serve/src/rest.rs

@@ -134,7 +134,7 @@ pub(crate) async fn start_rest_server(
 
     let service = ServiceBuilder::new()
         .concurrency_limit(quickwit_common::get_from_env("QW_REST_CONCURRENCY_LIMIT", 5))
-        .timeout(Duration::from_secs(1))
+        // .timeout(Duration::from_secs(1))
         .layer(
             CompressionLayer::new()
                 .gzip(true)