diff --git a/validator/src/journal/commit_store.rs b/validator/src/journal/commit_store.rs index ab3ccfe091..15bdba7d62 100644 --- a/validator/src/journal/commit_store.rs +++ b/validator/src/journal/commit_store.rs @@ -602,10 +602,10 @@ mod tests { .batches .into_iter() .find(|batch| { - !batch + batch .transaction_ids .iter() - .all(|txn_id| txn_id != transaction_id) + .any(|txn_id| txn_id == transaction_id) }) .ok_or_else(|| DatabaseError::CorruptionError("Transaction index corrupted".into())) // })