Updating to tokio 1.23 and updating unit tests.

Closes #2571
quickwit-oss · Dec 14, 2022 · e55d89e · e55d89e
1 parent d1d59fb
commit e55d89e
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 5 deletions.
diff --git a/quickwit/Cargo.lock b/quickwit/Cargo.lock
diff --git a/quickwit/Cargo.toml b/quickwit/Cargo.toml
@@ -155,7 +155,7 @@ thousands = "0.2.0"
 tikv-jemalloc-ctl = "0.5"
 tikv-jemallocator = "0.5"
 time = { version = "0.3.17", features = ["std", "formatting", "macros"] }
-tokio = { version = "^1.22", features = ["full", "test-util"] }
+tokio = { version = "1.23", features = ["full"] }
 tokio-stream = { version = "0.1", features = ["sync"] }
 tokio-util = { version = "0.7", features = ["full"] }
 toml = "0.5.9"

diff --git a/quickwit/quickwit-actors/src/mailbox.rs b/quickwit/quickwit-actors/src/mailbox.rs
@@ -421,6 +421,10 @@ mod tests {
         fn queue_capacity(&self) -> QueueCapacity {
             QueueCapacity::Bounded(0)
         }
+
+        fn yield_after_each_message(&self) -> bool {
+            false
+        }
     }
 
     use async_trait::async_trait;

diff --git a/quickwit/quickwit-actors/src/tests.rs b/quickwit/quickwit-actors/src/tests.rs
@@ -513,6 +513,10 @@ struct Adder(u64);
 impl Actor for Adder {
     type ObservableState = u64;
 
+    fn yield_after_each_message(&self) -> bool {
+        false
+    }
+
     fn observable_state(&self) -> Self::ObservableState {
         self.0
     }

diff --git a/quickwit/quickwit-storage/Cargo.toml b/quickwit/quickwit-storage/Cargo.toml
@@ -32,7 +32,7 @@ serde_json = { workspace = true }
 tantivy = { workspace = true }
 tempfile = { workspace = true }
 thiserror = { workspace = true }
-tokio = { workspace = true }
+tokio = { workspace = true, features = ["test-util"] }
 tokio-stream = { workspace = true }
 tokio-util = { workspace = true }
 tracing = { workspace = true }