From db6edabe2a96af258357db218ff13e1905670320 Mon Sep 17 00:00:00 2001 From: luofucong Date: Mon, 26 Jun 2023 17:41:23 +0800 Subject: [PATCH] rebase --- src/meta-srv/src/service/store/txn.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/meta-srv/src/service/store/txn.rs b/src/meta-srv/src/service/store/txn.rs index aaaf7b953acc..a636474f1e83 100644 --- a/src/meta-srv/src/service/store/txn.rs +++ b/src/meta-srv/src/service/store/txn.rs @@ -301,7 +301,7 @@ mod tests { async fn test_txn_compare_equal() { let kv_store = create_kv_store().await; let key = vec![101u8]; - kv_store.delete(key.clone(), false).await.unwrap(); + assert!(kv_store.delete(key.clone(), false).await.is_ok()); let txn = Txn::new() .when(vec![Compare::with_not_exist_value( @@ -332,7 +332,7 @@ mod tests { async fn test_txn_compare_greater() { let kv_store = create_kv_store().await; let key = vec![102u8]; - kv_store.delete(key.clone(), false).await.unwrap(); + assert!(kv_store.delete(key.clone(), false).await.is_ok()); let txn = Txn::new() .when(vec![Compare::with_not_exist_value( @@ -375,7 +375,7 @@ mod tests { async fn test_txn_compare_less() { let kv_store = create_kv_store().await; let key = vec![103u8]; - kv_store.delete(vec![3], false).await.unwrap(); + assert!(kv_store.delete(vec![3], false).await.is_ok()); let txn = Txn::new() .when(vec![Compare::with_not_exist_value( @@ -418,7 +418,7 @@ mod tests { async fn test_txn_compare_not_equal() { let kv_store = create_kv_store().await; let key = vec![104u8]; - kv_store.delete(key.clone(), false).await.unwrap(); + assert!(kv_store.delete(key.clone(), false).await.is_ok()); let txn = Txn::new() .when(vec![Compare::with_not_exist_value(