Crate update / cleanup

Author: Sushisource

Cargo.toml

@@ -8,7 +8,7 @@ license-file = "LICENSE.txt"
 
 [workspace.dependencies]
 derive_builder = "0.20"
-derive_more = { version = "1.0", features = ["constructor", "display", "from", "into", "debug"] }
+derive_more = { version = "2.0", features = ["constructor", "display", "from", "into", "debug"] }
 thiserror = "2"
 tonic = "0.12"
 tonic-build = "0.12"

client/Cargo.toml

@@ -28,7 +28,6 @@ hyper = { version = "1.4.1" }
 hyper-util = "0.1.6"
 opentelemetry = { workspace = true, features = ["metrics"], optional = true }
 parking_lot = "0.12"
-prost-types = { workspace = true }
 slotmap = "1.0"
 thiserror = { workspace = true }
 tokio = "1.1"

core-api/Cargo.toml

@@ -21,7 +21,6 @@ derive_builder = { workspace = true }
 derive_more = { workspace = true }
 opentelemetry = { workspace = true, optional = true }
 prost = { workspace = true }
-prost-types = { workspace = true }
 serde_json = "1.0"
 thiserror = { workspace = true }
 tonic = { workspace = true }

core/Cargo.toml

@@ -35,12 +35,12 @@ enum-iterator = "2"
 flate2 = { version = "1.0", optional = true }
 futures-util = { version = "0.3", default-features = false }
 futures-channel = { version = "0.3", default-features = false, features = ["std"] }
-governor = "0.7"
+governor = "0.8"
 http-body-util = { version = "0.1", optional = true }
 hyper = { version = "1.2", optional = true }
 hyper-util = { version = "0.1", features = ["server", "http1", "http2", "tokio"], optional = true }
-itertools = "0.13"
-lru = "0.12"
+itertools = "0.14"
+lru = "0.13"
 mockall = "0.13"
 opentelemetry = { workspace = true, features = ["metrics"], optional = true }
 opentelemetry_sdk = { version = "0.26", features = ["rt-tokio", "metrics"], optional = true }
@@ -52,14 +52,14 @@ pin-project = "1.0"
 prometheus = "0.13"
 prost = { workspace = true }
 prost-types = { version = "0.6", package = "prost-wkt-types" }
-rand = "0.8.3"
+rand = "0.9"
 reqwest = { version = "0.12", features = ["json", "stream", "rustls-tls-native-roots"], default-features = false, optional = true }
 ringbuf = "0.4"
 serde = "1.0"
 serde_json = "1.0"
 siphasher = "1.0"
 slotmap = "1.0"
-sysinfo = { version = "0.32", default-features = false, features = ["system"] }
+sysinfo = { version = "0.33", default-features = false, features = ["system"] }
 tar = { version = "0.4", optional = true }
 thiserror = { workspace = true }
 tokio = { version = "1.37", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs", "process"] }

sdk-core-protos/Cargo.toml

@@ -19,10 +19,9 @@ anyhow = "1.0"
 base64 = "0.22"
 derive_more = { workspace = true }
 prost = { workspace = true }
-prost-types = { workspace = true }
 prost-wkt = "0.6"
 prost-wkt-types = "0.6"
-rand = { version = "0.8", optional = true }
+rand = { version = "0.9", optional = true }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 thiserror = { workspace = true }

sdk/Cargo.toml

@@ -12,7 +12,6 @@ categories = ["development-tools"]
 
 [dependencies]
 async-trait = "0.1"
-thiserror = { workspace = true }
 anyhow = "1.0"
 derive_more = { workspace = true }
 futures-util = { version = "0.3", default-features = false }

test-utils/Cargo.toml

@@ -17,25 +17,17 @@ ephemeral-server = ["temporal-sdk-core/ephemeral-server"]
 anyhow = "1.0"
 assert_matches = "1"
 async-trait = "0.1"
-base64 = "0.22"
-bytes = "1.3"
 futures-util = { version = "0.3", default-features = false }
 parking_lot = "0.12"
 prost = { workspace = true }
-prost-types = { workspace = true }
-rand = "0.8"
-rmp-serde = "1.1"
-serde_json = "1.0"
+rand = "0.9"
 temporal-client = { path = "../client" }
 temporal-sdk = { path = "../sdk" }
 temporal-sdk-core = { path = "../core" }
 temporal-sdk-core-api = { path = "../core-api" }
-thiserror = { workspace = true }
 tokio = "1.1"
-tokio-util = { version = "0.7" }
 tracing = "0.1"
 url = "2.2"
-uuid = "1.1"
 
 [dependencies.temporal-sdk-core-protos]
 path = "../sdk-core-protos"

test-utils/src/canned_histories.rs

@@ -767,7 +767,7 @@ pub fn lots_of_big_signals(num_tasks: usize) -> TestHistoryBuilder {
     t.add_by_type(EventType::WorkflowExecutionStarted);
     t.add_full_wf_task();
 
-    let mut rng = rand::thread_rng();
+    let mut rng = rand::rng();
     for _ in 1..=num_tasks {
         let mut dat = [0_u8; 1024 * 1000];
         for _ in 1..=5 {

test-utils/src/lib.rs

@@ -16,7 +16,7 @@ use assert_matches::assert_matches;
 use futures_util::{StreamExt, future, stream, stream::FuturesUnordered};
 use parking_lot::Mutex;
 use prost::Message;
-use rand::{Rng, distributions};
+use rand::Rng;
 use std::{
     convert::TryFrom, env, future::Future, net::SocketAddr, path::PathBuf, sync::Arc,
     time::Duration,
@@ -874,8 +874,8 @@ pub async fn drain_pollers_and_shutdown(worker: &Arc<dyn CoreWorker>) {
 }
 
 pub fn rand_6_chars() -> String {
-    rand::thread_rng()
-        .sample_iter(&distributions::Alphanumeric)
+    rand::rng()
+        .sample_iter(&rand::distr::Alphanumeric)
         .take(6)
         .map(char::from)
         .collect()

tests/fuzzy_workflow.rs

@@ -21,7 +21,7 @@ enum FuzzyWfAction {
 struct FuzzyWfActionSampler;
 impl Distribution<FuzzyWfAction> for FuzzyWfActionSampler {
     fn sample<R: Rng + ?Sized>(&self, rng: &mut R) -> FuzzyWfAction {
-        let v: u8 = rng.gen_range(1..=2);
+        let v: u8 = rng.random_range(1..=2);
         match v {
             1 => FuzzyWfAction::DoAct,
             2 => FuzzyWfAction::DoLocalAct,