diff --git a/quickwit/Cargo.lock b/quickwit/Cargo.lock index b47d1887a8..01176f85a8 100644 --- a/quickwit/Cargo.lock +++ b/quickwit/Cargo.lock @@ -5376,9 +5376,9 @@ checksum = "cda74da7e1a664f795bb1f8a87ec406fb89a02522cf6e50620d016add6dbbf5c" [[package]] name = "tokio" -version = "1.22.0" +version = "1.23.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d76ce4a75fb488c605c54bf610f221cea8b0dafb53333c1a67e8ee199dcd2ae3" +checksum = "eab6d665857cc6ca78d6e80303a02cea7a7851e85dfbd77cbdc09bd129f1ef46" dependencies = [ "autocfg", "bytes", @@ -5392,7 +5392,7 @@ dependencies = [ "socket2", "tokio-macros", "tracing", - "winapi 0.3.9", + "windows-sys 0.42.0", ] [[package]] diff --git a/quickwit/Cargo.toml b/quickwit/Cargo.toml index 58cf8cb27a..1410186254 100644 --- 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 index c7b730821e..b6df4c7542 100644 --- 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 index 5ece6c5183..02529fae7a 100644 --- 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 index 9f16220dc5..079f7d1024 100644 --- 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 }