File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -452,13 +452,13 @@ impl GcScheduler {
452452 table_tasks. push ( task) ;
453453
454454 // Limit concurrent table processing
455- if table_tasks. len ( ) >= self . config . max_concurrent_tables {
456- if let Some ( result) = table_tasks. next ( ) . await {
457- let ( success , regions ) = Self :: handle_table_result ( result ) ;
458- processed_tables += 1 ;
459- successful_tables += success ;
460- total_regions_processed += regions ;
461- }
455+ if table_tasks. len ( ) >= self . config . max_concurrent_tables
456+ && let Some ( result) = table_tasks. next ( ) . await
457+ {
458+ let ( success , regions ) = Self :: handle_table_result ( result ) ;
459+ processed_tables += 1 ;
460+ successful_tables += success ;
461+ total_regions_processed += regions ;
462462 }
463463 }
464464
You can’t perform that action at this time.
0 commit comments