test(concurrency): test finish_execution_during_commit (#1904)

crates/blockifier/src/concurrency/scheduler.rs

@@ -106,9 +106,7 @@ impl Scheduler {
     /// already scheduled.
     pub fn finish_execution(&self, tx_index: TxIndex) {
         self.set_executed_status(tx_index);
-        if self.validation_index.load(Ordering::Acquire) > tx_index {
-            self.decrease_validation_index(tx_index);
-        }
+        self.decrease_validation_index(tx_index);
     }
 
     pub fn try_validation_abort(&self, tx_index: TxIndex) -> bool {

crates/blockifier/src/concurrency/scheduler_test.rs

@@ -122,6 +122,21 @@ fn test_commit_flow(
     }
 }
 
+#[rstest]
+#[case::reduces_validation_index(0, 3)]
+#[case::does_not_reduce_validation_index(1, 0)]
+fn test_finish_execution_during_commit(
+    #[case] tx_index: TxIndex,
+    #[case] validation_index: TxIndex,
+) {
+    let target_index = tx_index + 1;
+    let scheduler =
+        default_scheduler!(chunk_size: DEFAULT_CHUNK_SIZE, validation_index: validation_index);
+    scheduler.finish_execution_during_commit(tx_index);
+    let expected_validation_index = min(target_index, validation_index);
+    assert_eq!(scheduler.validation_index.load(Ordering::Acquire), expected_validation_index);
+}
+
 #[rstest]
 #[case::happy_flow(TransactionStatus::Executing)]
 #[should_panic(expected = "Only executing transactions can gain status executed. Transaction 0 \