[chore] update deps

Author: AhmedSoliman

Cargo.lock

@@ -29,7 +29,7 @@ resolver = "2"
 version = "1.6.0-dev"
 authors = ["restate.dev"]
 edition = "2024"
-rust-version = "1.88.0"
+rust-version = "1.90.0"
 license = "BUSL-1.1"
 repository = "https://github.com/restatedev/restate"
 homepage = "https://github.com/restatedev/restate"
@@ -133,11 +133,11 @@ datafusion = { version = "50.0.0", default-features = false, features = [
 datafusion-expr = { version = "50.0.0" }
 derive_builder = "0.20.0"
 derive_more = { version = "2.0.1", features = ["full"] }
-dialoguer = { version = "0.11.0" }
+dialoguer = { version = "0.12.0" }
 downcast-rs = { version = "2.0.1" }
 enum-map = { version = "2.7.3" }
 enumset = { version = "1.1.3" }
-etcd-client = { version = "0.14" }
+etcd-client = { version = "0.17" }
 flexbuffers = { version = "25.2.10" }
 futures = "0.3.25"
 futures-sink = "0.3.25"
@@ -173,24 +173,23 @@ moka = "0.12.5"
 mockall = { version = "0.13.1" }
 num-traits = { version = "0.2.17" }
 object_store = { version = "0.12.4", features = ["aws", "azure", "gcp"] }
-opentelemetry = { version = "0.30" }
-opentelemetry-contrib = { version = "0.22" }
-opentelemetry-http = { version = "0.30" }
-opentelemetry-otlp = { version = "0.30" }
-opentelemetry-semantic-conventions = { version = "0.30" }
-opentelemetry_sdk = { version = "0.30" }
+opentelemetry = { version = "0.31" }
+opentelemetry-contrib = { version = "0.23" }
+opentelemetry-http = { version = "0.31" }
+opentelemetry-otlp = { version = "0.31" }
+opentelemetry-semantic-conventions = { version = "0.31" }
+opentelemetry_sdk = { version = "0.31" }
 parking_lot = { version = "0.12" }
 paste = "1.0"
 pin-project = "1.0"
 pin-project-lite = { version = "0.2" }
 prost = { version = "0.14.1" }
 prost-build = { version = "0.14.1" }
-priority-queue = "2.0.3"
-prost-dto = { version = "0.0.3" }
+priority-queue = { version = "2.7.0" }
+prost-dto = { version = "0.0.4" }
 prost-types = { version = "0.14.1" }
 rand = "0.9.0"
 rangemap = "1.5.1"
-rayon = { version = "1.10" }
 regex = { version = "1.11" }
 reqwest = { version = "0.12", default-features = false, features = [
     "json",
@@ -214,7 +213,6 @@ sha2 = "0.10.8"
 smartstring = { version = "1.0.1" }
 static_assertions = { version = "1.1.0" }
 strum = { version = "0.27.1", features = ["derive"] }
-sync_wrapper = "1.0.1"
 smallvec = { version = "1.15.1", features = ["serde", "union"] }
 tempfile = "3.6.0"
 test-log = { version = "0.2.11", default-features = false, features = [
@@ -234,7 +232,7 @@ tokio = { version = "1.47.0", default-features = false, features = [
 ] }
 tokio-stream = "0.1.17"
 tokio-util = { version = "0.7.14" }
-toml = { version = "0.8.23" }
+toml = { version = "0.9" }
 tonic = { version = "0.14.2", default-features = false }
 tonic-reflection = { version = "0.14.2" }
 tonic-health = { version = "0.14.2" }
@@ -243,14 +241,14 @@ tonic-prost-build = { version = "0.14.2" }
 tower = "0.5.2"
 tower-http = { version = "0.6.2", default-features = false }
 tracing = { version = "0.1" }
-tracing-opentelemetry = { version = "0.31.0" }
+tracing-opentelemetry = { version = "0.32.0" }
 tracing-subscriber = { version = "0.3", features = [
     "env-filter",
     "fmt",
     "parking_lot",
 ] }
 tracing-test = { version = "0.2.5" }
-typed-builder = "0.21.0"
+typed-builder = "0.23.0"
 ulid = { version = "1.2.0" }
 url = { version = "2.5" }
 urlencoding = { version = "2.1" }

Cargo.toml

@@ -105,7 +105,10 @@ pub fn confirm_or_exit(prompt: &str) -> anyhow::Result<()> {
     Ok(())
 }
 
-pub fn choose<T: ToString>(prompt: &str, choices: &[T]) -> anyhow::Result<usize> {
+pub fn choose<T: ToString + std::fmt::Display>(
+    prompt: &str,
+    choices: &[T],
+) -> anyhow::Result<usize> {
     let theme = dialoguer::theme::ColorfulTheme::default();
     Ok(dialoguer::Select::with_theme(&theme)
         .with_prompt(prompt)

crates/cli-util/src/ui/console.rs

@@ -77,7 +77,7 @@ impl<M> Incoming<M> {
     /// incoming message, use [`Self::parent_context()`] instead
     pub fn follow_from_sender(&mut self) {
         if let Some(context) = self.parent_context.take() {
-            Span::current().set_parent(context)
+            let _ = Span::current().set_parent(context);
         }
     }
 
@@ -91,7 +91,7 @@ impl<M> Incoming<M> {
     /// incoming message, use [`Self::parent_context()`] instead
     pub fn follow_from_sender_for(&mut self, span: &Span) {
         if let Some(context) = self.parent_context.take() {
-            span.set_parent(context)
+            let _ = span.set_parent(context);
         }
     }
 }

crates/core/src/network/incoming.rs

@@ -16,7 +16,7 @@ restate-workspace-hack = { workspace = true }
 
 restate-types = { workspace = true }
 
-ahash = "0.8.3"
+ahash = { workspace = true }
 pin-project = { workspace = true }
 priority-queue = { workspace = true }
 schemars = { workspace = true, optional = true }
@@ -29,4 +29,4 @@ restate-test-util = { workspace = true }
 
 futures-util = { workspace = true }
 tracing-subscriber = { workspace = true }
-test-log = { workspace = true }
+test-log = { workspace = true }

crates/timer/Cargo.toml

@@ -43,8 +43,7 @@ reqwest = { workspace = true }
 schemars = { workspace = true, optional = true }
 thiserror = { workspace = true }
 tokio = { workspace = true, optional = true }
-# using version 0.13.1 which is required by opentelemetry-otlp
-tonic = { version = "0.13.1", features = ["tls-native-roots"]}
+tonic = { workspace = true, features = ["tls-native-roots"]}
 tracing = { workspace = true }
 tracing-appender = { version = "0.2.3", features = ["parking_lot"] }
 tracing-core = { version = "0.1" }

crates/tracing-instrumentation/Cargo.toml

@@ -66,7 +66,7 @@ listenfd = { version = "1" }
 metrics = { workspace = true }
 moka = { workspace = true, features = ["sync", "logging"] }
 notify = { version = "8.0.0" }
-notify-debouncer-full = { version = "0.5" }
+notify-debouncer-full = { version = "0.6" }
 num-traits = { workspace = true }
 opentelemetry = { workspace = true , features = ["trace"]}
 parking_lot = { workspace = true }
@@ -88,7 +88,6 @@ smallvec = { workspace = true }
 smartstring = { workspace = true, features = ["serde"]}
 static_assertions = { workspace = true }
 strum = { workspace = true }
-sync_wrapper = { workspace = true }
 tempfile = { workspace = true, optional = true }
 thiserror = { workspace = true }
 tiny-gradient = { version = "0.1.0" }

crates/types/Cargo.toml

@@ -8,7 +8,6 @@
 // the Business Source License, use of this software will be governed
 // by the Apache License, Version 2.0.
 
-use std::any::Any;
 use std::borrow::Cow;
 use std::convert::Into;
 use std::fmt;
@@ -381,14 +380,6 @@ pub enum IdDecodeError {
     UnrecognizedType(String),
 }
 
-#[derive(Debug, thiserror::Error)]
-pub enum ThreadJoinError {
-    #[error("thread panicked: {0:?}")]
-    Panic(sync_wrapper::SyncWrapper<Box<dyn Any + Send + 'static>>),
-    #[error("thread terminated unexpectedly")]
-    UnexpectedTermination,
-}
-
 #[derive(Debug, thiserror::Error)]
 pub enum ConversionError {
     #[error("missing field '{0}'")]

crates/types/src/errors.rs

@@ -91,16 +91,6 @@ pub enum BuildError {
     SnapshotRepository(#[from] anyhow::Error),
 }
 
-#[derive(Debug, thiserror::Error, CodedError)]
-pub enum Error {
-    #[error("thread '{thread}' panicked: {cause}")]
-    #[code(unknown)]
-    ThreadPanic {
-        thread: &'static str,
-        cause: restate_types::errors::ThreadJoinError,
-    },
-}
-
 pub struct Worker {
     storage_query_context: QueryContext,
     datafusion_remote_scanner: RemoteQueryScannerServer,

crates/worker/src/lib.rs

@@ -87,12 +87,12 @@ num-bigint = { version = "0.4" }
 num-integer = { version = "0.1", features = ["i128"] }
 num-traits = { version = "0.2", features = ["i128", "libm"] }
 object_store = { version = "0.12", features = ["aws", "azure", "gcp"] }
-opentelemetry_sdk = { version = "0.30", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
+opentelemetry = { version = "0.31" }
+opentelemetry_sdk = { version = "0.31", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
 phf_shared = { version = "0.11" }
 pprof = { version = "0.15", features = ["criterion", "flamegraph", "frame-pointer"] }
 proc-macro2 = { version = "1" }
 prost-582f2526e08bb6a0 = { package = "prost", version = "0.14" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["prost-derive"] }
 prost-types = { version = "0.14" }
 protobuf = { version = "2", default-features = false, features = ["with-bytes"] }
 quanta = { version = "0.12" }
@@ -124,7 +124,7 @@ tokio-stream = { version = "0.1", features = ["net", "sync"] }
 tokio-util = { version = "0.7", features = ["codec", "io-util", "net", "rt"] }
 toml_datetime = { version = "0.6", default-features = false, features = ["serde"] }
 toml_edit = { version = "0.22", features = ["serde"] }
-tonic = { version = "0.14", default-features = false, features = ["codegen", "gzip", "router", "transport", "zstd"] }
+tonic = { version = "0.14", features = ["gzip", "tls-native-roots", "tls-ring", "zstd"] }
 tower-9fbad63c4bcf4a8f = { package = "tower", version = "0.4", features = ["balance", "buffer", "limit", "util"] }
 tower-d8f496e17d97b5cb = { package = "tower", version = "0.5", default-features = false, features = ["balance", "buffer", "limit", "load-shed", "log", "retry", "timeout"] }
 tower-http = { version = "0.6", features = ["cors", "follow-redirect", "map-response-body", "normalize-path", "trace"] }
@@ -216,12 +216,12 @@ num-bigint = { version = "0.4" }
 num-integer = { version = "0.1", features = ["i128"] }
 num-traits = { version = "0.2", features = ["i128", "libm"] }
 object_store = { version = "0.12", features = ["aws", "azure", "gcp"] }
-opentelemetry_sdk = { version = "0.30", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
+opentelemetry = { version = "0.31" }
+opentelemetry_sdk = { version = "0.31", features = ["experimental_trace_batch_span_processor_with_async_runtime", "rt-tokio"] }
 phf_shared = { version = "0.11" }
 pprof = { version = "0.15", features = ["criterion", "flamegraph", "frame-pointer"] }
 proc-macro2 = { version = "1" }
 prost-582f2526e08bb6a0 = { package = "prost", version = "0.14" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["prost-derive"] }
 prost-build = { version = "0.14", features = ["cleanup-markdown"] }
 prost-types = { version = "0.14" }
 protobuf = { version = "2", default-features = false, features = ["with-bytes"] }
@@ -255,7 +255,7 @@ tokio-stream = { version = "0.1", features = ["net", "sync"] }
 tokio-util = { version = "0.7", features = ["codec", "io-util", "net", "rt"] }
 toml_datetime = { version = "0.6", default-features = false, features = ["serde"] }
 toml_edit = { version = "0.22", features = ["serde"] }
-tonic = { version = "0.14", default-features = false, features = ["codegen", "gzip", "router", "transport", "zstd"] }
+tonic = { version = "0.14", features = ["gzip", "tls-native-roots", "tls-ring", "zstd"] }
 tower-9fbad63c4bcf4a8f = { package = "tower", version = "0.4", features = ["balance", "buffer", "limit", "util"] }
 tower-d8f496e17d97b5cb = { package = "tower", version = "0.5", default-features = false, features = ["balance", "buffer", "limit", "load-shed", "log", "retry", "timeout"] }
 tower-http = { version = "0.6", features = ["cors", "follow-redirect", "map-response-body", "normalize-path", "trace"] }
@@ -280,7 +280,7 @@ libc = { version = "0.2", default-features = false, features = ["use_std"] }
 mio = { version = "1", features = ["net", "os-ext"] }
 nix = { version = "0.29", features = ["fs", "signal"] }
 num = { version = "0.4" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
+prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
 rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
 rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }
 
@@ -292,7 +292,7 @@ libc = { version = "0.2", default-features = false, features = ["use_std"] }
 mio = { version = "1", features = ["net", "os-ext"] }
 nix = { version = "0.29", features = ["fs", "signal"] }
 num = { version = "0.4" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
+prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
 rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
 rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }
 
@@ -303,7 +303,7 @@ hyper-util = { version = "0.1", default-features = false, features = ["client-pr
 libc = { version = "0.2", default-features = false, features = ["use_std"] }
 nix = { version = "0.29", features = ["fs", "signal"] }
 num = { version = "0.4" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
+prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
 rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
 rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }
 
@@ -314,7 +314,7 @@ hyper-util = { version = "0.1", default-features = false, features = ["client-pr
 libc = { version = "0.2", default-features = false, features = ["use_std"] }
 nix = { version = "0.29", features = ["fs", "signal"] }
 num = { version = "0.4" }
-prost-594e8ee84c453af0 = { package = "prost", version = "0.13", default-features = false, features = ["no-recursion-limit"] }
+prost-594e8ee84c453af0 = { package = "prost", version = "0.13", features = ["no-recursion-limit", "prost-derive"] }
 rustix-d585fab2519d2d1 = { package = "rustix", version = "0.38", features = ["stdio", "termios"] }
 rustix-dff4ba8e3ae991db = { package = "rustix", version = "1", features = ["fs", "stdio", "termios"] }