aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-07-04 12:53:47 +0200
committerAlex Auvolat <alex@adnab.me>2022-07-08 10:41:57 +0200
commitaab34bfe5415e9584432bf32e29a151dc5af9ebd (patch)
tree014e6734798040eb80e17f705904b41f13953240
parentfe3fa83de74b79ffeeb2042c58b9360defa65431 (diff)
downloadgarage-aab34bfe5415e9584432bf32e29a151dc5af9ebd.tar.gz
garage-aab34bfe5415e9584432bf32e29a151dc5af9ebd.zip
add delays in k2v test_items_and_indices
-rw-r--r--src/garage/tests/k2v/item.rs6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/garage/tests/k2v/item.rs b/src/garage/tests/k2v/item.rs
index bf2b01f8..32537336 100644
--- a/src/garage/tests/k2v/item.rs
+++ b/src/garage/tests/k2v/item.rs
@@ -1,3 +1,5 @@
+use std::time::Duration;
+
use crate::common;
use assert_json_diff::assert_json_eq;
@@ -86,6 +88,7 @@ async fn test_items_and_indices() {
assert_eq!(res_body, content);
// ReadIndex -- now there should be some stuff
+ tokio::time::sleep(Duration::from_secs(1)).await;
let res = ctx
.k2v
.request
@@ -154,6 +157,7 @@ async fn test_items_and_indices() {
assert_eq!(res_body, content2);
// ReadIndex -- now there should be some stuff
+ tokio::time::sleep(Duration::from_secs(1)).await;
let res = ctx
.k2v
.request
@@ -222,6 +226,7 @@ async fn test_items_and_indices() {
);
// ReadIndex -- now there should be some stuff
+ tokio::time::sleep(Duration::from_secs(1)).await;
let res = ctx
.k2v
.request
@@ -290,6 +295,7 @@ async fn test_items_and_indices() {
assert_eq!(res.status(), 204);
// ReadIndex -- now there should be some stuff
+ tokio::time::sleep(Duration::from_secs(1)).await;
let res = ctx
.k2v
.request