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

try fix unstable case 

Signed-off-by: haojinming <jinming.hao@pingcap.com>
This commit is contained in:
haojinming 2023-01-19 12:16:30 +08:00
parent f7a82d1001
commit 54cfaa523f
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/failpoint_tests.rs
View File

@ -34,7 +34,9 @@ async fn txn_optimistic_heartbeat() -> Result<()> {
let mut txn_without_heartbeat = client let mut txn_without_heartbeat = client
.begin_with_options( .begin_with_options(
TransactionOptions::new_optimistic().heartbeat_option(HeartbeatOption::NoHeartbeat), TransactionOptions::new_optimistic()
.heartbeat_option(HeartbeatOption::NoHeartbeat)
.drop_check(tikv_client::CheckLevel::Warn),
) )
.await?; .await?;
txn_without_heartbeat txn_without_heartbeat
@ -58,7 +60,8 @@ async fn txn_optimistic_heartbeat() -> Result<()> {
.begin_with_options( .begin_with_options(
TransactionOptions::new_optimistic() TransactionOptions::new_optimistic()
.no_resolve_locks() .no_resolve_locks()
.heartbeat_option(HeartbeatOption::NoHeartbeat), .heartbeat_option(HeartbeatOption::NoHeartbeat)
.drop_check(tikv_client::CheckLevel::Warn),
) )
.await?; .await?;
t3.put(key1.clone(), "gee").await?; t3.put(key1.clone(), "gee").await?;