File tree 1 file changed +3
-0
lines changed
quickwit/quickwit-indexing/src/source
1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -307,6 +307,7 @@ mod tests {
307
307
let doc_batches: Vec < RawDocBatch > = doc_processor_inbox. drain_for_test_typed ( ) ;
308
308
assert_eq ! ( doc_batches. len( ) , 2 ) ;
309
309
assert ! ( doc_batches[ 1 ] . docs[ 0 ] . starts_with( "038462" ) ) ;
310
+ ingest_api_source_handle. quit ( ) . await ;
310
311
universe. assert_quit ( ) . await ;
311
312
Ok ( ( ) )
312
313
}
@@ -407,6 +408,7 @@ mod tests {
407
408
doc_batches[ 0 ] . checkpoint_delta. partitions( ) . next( ) . unwrap( ) ,
408
409
& partition_id
409
410
) ;
411
+ ingest_api_source_handle. quit ( ) . await ;
410
412
universe. assert_quit ( ) . await ;
411
413
412
414
Ok ( ( ) )
@@ -459,6 +461,7 @@ mod tests {
459
461
let doc_batches: Vec < RawDocBatch > = doc_processor_inbox. drain_for_test_typed ( ) ;
460
462
assert_eq ! ( doc_batches. len( ) , 1 ) ;
461
463
assert ! ( doc_batches[ 0 ] . docs[ 0 ] . starts_with( "000000" ) ) ;
464
+ ingest_api_source_handle. quit ( ) . await ;
462
465
universe. assert_quit ( ) . await ;
463
466
Ok ( ( ) )
464
467
}
You can’t perform that action at this time.
0 commit comments