File tree Expand file tree Collapse file tree 1 file changed +11
-8
lines changed
quickwit/quickwit-integration-tests/src/tests Expand file tree Collapse file tree 1 file changed +11
-8
lines changed Original file line number Diff line number Diff line change @@ -359,14 +359,17 @@ async fn test_ingest_v2_high_throughput() {
359359 let line = json ! ( { "body" : "my dummy repeated payload" } ) . to_string ( ) ;
360360 let num_docs = body_size / line. len ( ) ;
361361 let body = std:: iter:: repeat_n ( & line, num_docs) . join ( "\n " ) ;
362- let ingest_resp = ingest (
363- & sandbox. rest_client ( QuickwitService :: Indexer ) ,
364- index_id,
365- IngestSource :: Str ( body) ,
366- CommitType :: Auto ,
367- )
368- . await
369- . unwrap ( ) ;
362+ let ingest_resp = sandbox
363+ . rest_client ( QuickwitService :: Indexer )
364+ . ingest (
365+ index_id,
366+ IngestSource :: Str ( body) ,
367+ Some ( 5_000_000 ) ,
368+ None ,
369+ CommitType :: Auto ,
370+ )
371+ . await
372+ . unwrap ( ) ;
370373 assert_eq ! ( ingest_resp. num_docs_for_processing, num_docs as u64 ) ;
371374 assert_eq ! ( ingest_resp. num_ingested_docs, Some ( num_docs as u64 ) ) ;
372375 assert_eq ! ( ingest_resp. num_rejected_docs, Some ( 0 ) ) ;
You can’t perform that action at this time.
0 commit comments