File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
forester/src/processor/v2 Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -403,7 +403,7 @@ impl<R: Rpc> BatchProcessor<R> {
403
403
cache. add ( & batch_hash) ;
404
404
}
405
405
406
- // Ensure changelog cache exists (but don't clear it)
406
+
407
407
let _ = changelog_cache:: get_changelog_cache ( ) . await ;
408
408
409
409
// Create nullify stream
@@ -464,7 +464,7 @@ impl<R: Rpc> BatchProcessor<R> {
464
464
cache. add ( & batch_hash) ;
465
465
}
466
466
467
- // Ensure changelog cache exists (but don't clear it)
467
+
468
468
let _ = changelog_cache:: get_changelog_cache ( ) . await ;
469
469
470
470
// Create append stream
@@ -511,7 +511,7 @@ impl<R: Rpc> BatchProcessor<R> {
511
511
) -> Result < usize > {
512
512
info ! ( "Processing state operations in parallel with changelog cache" ) ;
513
513
514
- // Ensure changelog cache exists (but don't clear it)
514
+
515
515
let _ = changelog_cache:: get_changelog_cache ( ) . await ;
516
516
517
517
// Create futures for stream creation
You can’t perform that action at this time.
0 commit comments