tikv
/
client-rust
mirror of https://github.com/tikv/client-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix unstable test 

Signed-off-by: haojinming <jinming.hao@pingcap.com>
This commit is contained in:
haojinming 2023-01-04 17:58:23 +08:00
parent a04e5510a7
commit b700e306a6
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/request/plan.rs
View File

@ -479,7 +479,7 @@ impl Merge<CleanupLocksResult> for Collect {
.into_iter() .into_iter()
.fold(Ok(CleanupLocksResult::default()), |acc, x| { .fold(Ok(CleanupLocksResult::default()), |acc, x| {
Ok(CleanupLocksResult { Ok(CleanupLocksResult {
meet_locks: acc.unwrap().meet_locks + x?.meet_locks, meet_locks: acc?.meet_locks + x?.meet_locks,
..Default::default() ..Default::default()
}) })
}) })

2
tests/integration_tests.rs
View File

@ -894,7 +894,7 @@ async fn txn_scan_reverse() -> Result<()> {
]; ];
// pessimistic // pessimistic
let option = TransactionOptions::new_pessimistic().drop_check(tikv_client::CheckLevel::Warn); let option = TransactionOptions::new_optimistic().drop_check(tikv_client::CheckLevel::Warn);
let mut t = client.begin_with_options(option.clone()).await?; let mut t = client.begin_with_options(option.clone()).await?;
t.put(k1.clone(), v1).await?; t.put(k1.clone(), v1).await?;
t.put(k2.clone(), v2).await?; t.put(k2.clone(), v2).await?;